diff --git a/src/test/java/org/springframework/data/redis/listener/PubSubResubscribeTests.java b/src/test/java/org/springframework/data/redis/listener/PubSubResubscribeTests.java index 1df3b5b06..ad682b6cc 100644 --- a/src/test/java/org/springframework/data/redis/listener/PubSubResubscribeTests.java +++ b/src/test/java/org/springframework/data/redis/listener/PubSubResubscribeTests.java @@ -168,8 +168,8 @@ public class PubSubResubscribeTests { String ANOTHER_CHANNEL = "pubsub::test::extra"; // bind listener on another channel - container.removeMessageListener(null, new ChannelTopic(CHANNEL)); container.addMessageListener(adapter, new ChannelTopic(ANOTHER_CHANNEL)); + container.removeMessageListener(null, new ChannelTopic(CHANNEL)); assertEquals(ZERO, template.convertAndSend(CHANNEL, payload1)); assertEquals(ZERO, template.convertAndSend(CHANNEL, payload2));