diff --git a/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java b/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java
index 2458a9a7c..548a61c81 100644
--- a/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java
+++ b/redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java
@@ -300,11 +300,12 @@ public class PublishSubscribeService {
 
         ChannelName channelName = new ChannelName("__redis__:invalidate");
 
-        RedisPubSubListener<String> redisPubSubListener = new RedisPubSubListener<String>() {
+        RedisPubSubListener<Object> redisPubSubListener = new RedisPubSubListener<Object>() {
             @Override
-            public void onMessage(CharSequence channel, String msg) {
-                if (key.equals(msg)) {
-                    listener.onChange(msg);
+            public void onMessage(CharSequence channel, Object msg) {
+                if (channel.equals(channelName.toString())
+                        && key.equals(msg)) {
+                    listener.onChange((String) msg);
                 }
             }
         };