From e5389b3e9b6b40a16d4254a68d49071eb1c1557c Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Mon, 27 Nov 2023 12:38:50 +0300 Subject: [PATCH] tests fixed --- .../src/test/java/org/redisson/RedissonTopicTest.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/redisson/src/test/java/org/redisson/RedissonTopicTest.java b/redisson/src/test/java/org/redisson/RedissonTopicTest.java index cda7a0715..0cfeafd5f 100644 --- a/redisson/src/test/java/org/redisson/RedissonTopicTest.java +++ b/redisson/src/test/java/org/redisson/RedissonTopicTest.java @@ -482,13 +482,13 @@ public class RedissonTopicTest extends RedisDockerTest { } try { - Thread.sleep(1000); + Thread.sleep(2000); } catch (InterruptedException e) { throw new RuntimeException(e); } topic.publish("mymessage"); - Awaitility.waitAtMost(Duration.ofSeconds(1)).until(() -> reference.get().equals("mymessage")); + Awaitility.waitAtMost(Duration.ofSeconds(1)).until(() -> "mymessage".equals(reference.get())); List sourceList2 = sourceConnection.sync(RedisCommands.PUBSUB_CHANNELS); assertThat(sourceList2).isEmpty(); @@ -1470,6 +1470,8 @@ public class RedissonTopicTest extends RedisDockerTest { .addNode(master3, slave3); ClusterProcesses process = clusterRunner.run(); + Thread.sleep(5000); + Config config = new Config(); config.useClusterServers() .addNodeAddress(process.getNodes().stream().findAny().get().getRedisServerAddressAndPort()); @@ -1621,6 +1623,8 @@ public class RedissonTopicTest extends RedisDockerTest { .addNode(master3, slave3); ClusterProcesses process = clusterRunner.run(); + Thread.sleep(5000); + Config config = new Config(); config.useClusterServers() .setSubscriptionMode(SubscriptionMode.MASTER)