diff --git a/pom.xml b/pom.xml index 85683078..e53a59c4 100644 --- a/pom.xml +++ b/pom.xml @@ -46,7 +46,7 @@ 2026.0.0-SNAPSHOT - 1.76.0 + 1.79.0 4.34.0 2.0.16 @@ -60,7 +60,7 @@ 0.8.14 5.14.3 5.23.0 - 1.21.4 + 2.0.3 5.6 2.1.11 @@ -135,6 +135,21 @@ ${reactive.streams.version} test + + + + org.testng + testng + 7.11.0 + test + + + + org.apache.logging.log4j + log4j-core + ${log4j.version} + test + @@ -245,13 +260,13 @@ org.testcontainers - toxiproxy + testcontainers-toxiproxy ${testcontainers.version} test org.testcontainers - junit-jupiter + testcontainers-junit-jupiter ${testcontainers.version} test @@ -304,6 +319,12 @@ + + + + properties + + @@ -406,6 +427,7 @@ **/*Test_*.java **/*Tests_*.java + -javaagent:${org.mockito:mockito-core:jar} diff --git a/src/main/java/io/axoniq/axonserver/connector/Registration.java b/src/main/java/io/axoniq/axonserver/connector/Registration.java index 6b7c045e..7b0afde2 100644 --- a/src/main/java/io/axoniq/axonserver/connector/Registration.java +++ b/src/main/java/io/axoniq/axonserver/connector/Registration.java @@ -58,7 +58,7 @@ default Registration awaitAck(long timeout, TimeUnit unit) throws TimeoutExcepti * Registers the given {@code runnable} to {@code this} {@link Registration} to be executed when the acknowledgement * of {@code this} {@link Registration} is received. Allows for the addition of further logic to {@code this * Registration}, like invoking {@link #awaitAck(long, TimeUnit)} for example. - *

+ *

* The given {@code runnable} is invoked, regardless of successful or failed acknowledgement. Use * {@link #onAck(Consumer)} to register an action that needs to distinguish between successful and failed * registration. diff --git a/src/test/java/io/axoniq/axonserver/connector/admin/AdminChannelIntegrationTest.java b/src/test/java/io/axoniq/axonserver/connector/admin/AdminChannelIntegrationTest.java index af7e77a8..1c8dceb0 100644 --- a/src/test/java/io/axoniq/axonserver/connector/admin/AdminChannelIntegrationTest.java +++ b/src/test/java/io/axoniq/axonserver/connector/admin/AdminChannelIntegrationTest.java @@ -54,10 +54,10 @@ import static io.axoniq.axonserver.connector.testutils.AssertUtils.assertWithin; import static java.util.concurrent.TimeUnit.MILLISECONDS; import static java.util.concurrent.TimeUnit.SECONDS; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.fail; import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertFalse; import static org.junit.jupiter.api.Assertions.assertTrue; +import static org.junit.jupiter.api.Assertions.fail; import static org.mockito.Mockito.*; /** diff --git a/src/test/java/io/axoniq/axonserver/connector/event/dcb/DcbEndToEndTest.java b/src/test/java/io/axoniq/axonserver/connector/event/dcb/DcbEndToEndTest.java index 70be6730..d1b3381f 100644 --- a/src/test/java/io/axoniq/axonserver/connector/event/dcb/DcbEndToEndTest.java +++ b/src/test/java/io/axoniq/axonserver/connector/event/dcb/DcbEndToEndTest.java @@ -26,7 +26,6 @@ import org.junit.jupiter.api.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.testcontainers.containers.output.Slf4jLogConsumer; import reactor.core.publisher.Flux; import reactor.test.StepVerifier; @@ -92,8 +91,6 @@ void setUp() { } else { // Connect to Docker container builder.routingServers(axonServerAddress); - Slf4jLogConsumer logConsumer = new Slf4jLogConsumer(logger); - axonServerContainer.followOutput(logConsumer); } client = builder.build();