diff --git a/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java b/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java index 8e286fa..eb196e1 100644 --- a/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java +++ b/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java @@ -53,12 +53,12 @@ public class RedissonPubSubStore implements PubSubStore { @Override public void subscribe(PubSubType type, final PubSubListener listener, Class clazz) { String name = type.toString(); - RTopic topic = redissonSub.getTopic(name); - int regId = topic.addListener(new MessageListener() { + RTopic topic = redissonSub.getTopic(name); + int regId = topic.addListener(PubSubMessage.class, new MessageListener() { @Override - public void onMessage(CharSequence channel, T msg) { + public void onMessage(CharSequence channel, PubSubMessage msg) { if (!nodeId.equals(msg.getNodeId())) { - listener.onMessage(msg); + listener.onMessage((T)msg); } } }); @@ -78,7 +78,7 @@ public class RedissonPubSubStore implements PubSubStore { public void unsubscribe(PubSubType type) { String name = type.toString(); Queue regIds = map.remove(name); - RTopic topic = redissonSub.getTopic(name); + RTopic topic = redissonSub.getTopic(name); for (Integer id : regIds) { topic.removeListener(id); }