diff --git a/redis/src/test/java/com/baeldung/RedissonIntegrationTest.java b/redis/src/test/java/com/baeldung/RedissonIntegrationTest.java index 4cacd9dbd0..766963e5cf 100644 --- a/redis/src/test/java/com/baeldung/RedissonIntegrationTest.java +++ b/redis/src/test/java/com/baeldung/RedissonIntegrationTest.java @@ -104,9 +104,9 @@ public class RedissonIntegrationTest { RTopic subscribeTopic = client.getTopic("baeldung"); subscribeTopic.addListener((channel, customMessage) -> future.complete(customMessage.getMessage())); - RTopic receiveTopic = client.getTopic("baeldung"); + RTopic publishTopic = client.getTopic("baeldung"); long clientsReceivedMessage - = receiveTopic.publish(new CustomMessage("This is a message")); + = publishTopic.publish(new CustomMessage("This is a message")); assertEquals("This is a message", future.get());