fixed unit tests

Author: jruaux

src/test/java/com/redislabs/testcontainers/TestRedisClusterWithKeyspaceNotificationsContainer.java

@@ -48,6 +48,7 @@ void emitsKeyspaceNotifications() throws InterruptedException {
         pubSubConnection.addListener(new PubSubListener(messages));
         pubSubConnection.setNodeMessagePropagation(true);
         pubSubConnection.sync().upstream().commands().psubscribe("__keyspace@0__:*");
+        Thread.sleep(10);
         connection.sync().set("key1", "value");
         connection.sync().set("key2", "value");
         Thread.sleep(10);

src/test/java/com/redislabs/testcontainers/TestRedisStandaloneWithKeyspaceNotificationsContainer.java

@@ -45,6 +45,7 @@ void emitsKeyspaceNotifications() throws InterruptedException {
         List<String> messages = new ArrayList<>();
         pubSubConnection.addListener(new PubSubListener(messages));
         pubSubConnection.sync().psubscribe("__keyspace@0__:*");
+        Thread.sleep(10);
         connection.sync().set("key1", "value");
         connection.sync().set("key2", "value");
         Thread.sleep(10);