diff options
author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-09-28 14:02:10 +0200 |
---|---|---|
committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2021-09-28 14:03:06 +0200 |
commit | 3c2246b434117f44fca728d2abdaa17db3d4473b (patch) | |
tree | 6b92dd8f8b9a973d6c96a4133aba49752d28dd43 | |
parent | 50bd1c4ce981945e19feab4e69b4ad3273dbcfc1 (diff) | |
download | rabbitmq-server-git-3c2246b434117f44fca728d2abdaa17db3d4473b.tar.gz |
Bump dependencies in stream Java tests
(cherry picked from commit e8d0d380a2a8b46c3884c20690aaefea54a8af68)
4 files changed, 12 insertions, 12 deletions
diff --git a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/pom.xml b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/pom.xml index 22fdcc3008..000c1e4756 100644 --- a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/pom.xml +++ b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/pom.xml @@ -26,10 +26,10 @@ </developers> <properties> - <stream-client.version>0.4.0-SNAPSHOT</stream-client.version> - <junit.jupiter.version>5.7.2</junit.jupiter.version> - <assertj.version>3.20.2</assertj.version> - <logback.version>1.2.5</logback.version> + <stream-client.version>0.5.0-SNAPSHOT</stream-client.version> + <junit.jupiter.version>5.8.1</junit.jupiter.version> + <assertj.version>3.21.0</assertj.version> + <logback.version>1.2.6</logback.version> <maven.compiler.plugin.version>3.8.1</maven.compiler.plugin.version> <maven-surefire-plugin.version>2.22.2</maven-surefire-plugin.version> <spotless.version>2.2.0</spotless.version> diff --git a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java index 65142042e9..b806471207 100644 --- a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java +++ b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/FailureTest.java @@ -159,7 +159,7 @@ public class FailureTest { new Client.ClientParameters() .port(TestUtils.streamPortNode1()) .messageListener( - (subscriptionId, offset, msg) -> { + (subscriptionId, offset, chunkTimestamp, msg) -> { bodies.add(new String(msg.getBodyAsBinary(), StandardCharsets.UTF_8)); consumeLatch.countDown(); })); @@ -340,7 +340,7 @@ public class FailureTest { (client1, subscriptionId, offset, messageCount, dataSize) -> client1.credit(subscriptionId, 1)) .messageListener( - (subscriptionId, offset, message) -> { + (subscriptionId, offset, chunkTimestamp, message) -> { consumed.add(message); generations.add((Long) message.getApplicationProperties().get("generation")); if (consumed.size() == confirmed.size()) { @@ -443,7 +443,7 @@ public class FailureTest { Set<Long> generations = ConcurrentHashMap.newKeySet(); Set<Long> consumedIds = ConcurrentHashMap.newKeySet(); Client.MessageListener messageListener = - (subscriptionId, offset, message) -> { + (subscriptionId, offset, chunkTimestamp, message) -> { consumed.add(message); generations.add((Long) message.getApplicationProperties().get("generation")); consumedIds.add(message.getProperties().getMessageIdAsLong()); diff --git a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/StreamTest.java b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/StreamTest.java index a94de011f3..b02057ba35 100644 --- a/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/StreamTest.java +++ b/deps/rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream/StreamTest.java @@ -119,7 +119,7 @@ public class StreamTest { (client1, subscriptionId, offset, messageCount1, dataSize) -> client1.credit(subscriptionId, 10)) .messageListener( - (subscriptionId, offset, message) -> { + (subscriptionId, offset, chunkTimestamp, message) -> { bodies.add(new String(message.getBodyAsBinary(), StandardCharsets.UTF_8)); consumingLatch.countDown(); })); diff --git a/deps/rabbitmq_stream_management/test/http_SUITE_data/pom.xml b/deps/rabbitmq_stream_management/test/http_SUITE_data/pom.xml index d3885f3002..a2fc8a292b 100644 --- a/deps/rabbitmq_stream_management/test/http_SUITE_data/pom.xml +++ b/deps/rabbitmq_stream_management/test/http_SUITE_data/pom.xml @@ -26,12 +26,12 @@ </developers> <properties> - <stream-client.version>0.4.0-SNAPSHOT</stream-client.version> - <junit.jupiter.version>5.7.2</junit.jupiter.version> - <assertj.version>3.20.2</assertj.version> + <stream-client.version>0.5.0-SNAPSHOT</stream-client.version> + <junit.jupiter.version>5.8.1</junit.jupiter.version> + <assertj.version>3.21.0</assertj.version> <okhttp.version>4.9.1</okhttp.version> <gson.version>2.8.8</gson.version> - <logback.version>1.2.5</logback.version> + <logback.version>1.2.6</logback.version> <maven.compiler.plugin.version>3.8.1</maven.compiler.plugin.version> <maven-surefire-plugin.version>2.22.2</maven-surefire-plugin.version> <spotless.version>2.2.0</spotless.version> |