From 809931707ca2fe1a37da8aaa2a81af509e3f6b2b Mon Sep 17 00:00:00 2001 From: Nikita Date: Sat, 6 Oct 2018 20:16:19 +0300 Subject: [PATCH] Redisson compatibility fixed #602 --- pom.xml | 16 ++++++++-------- .../socketio/store/RedissonPubSubStore.java | 2 +- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/pom.xml b/pom.xml index 94a80c7..f0d6385 100644 --- a/pom.xml +++ b/pom.xml @@ -85,37 +85,37 @@ io.netty netty-buffer - 4.1.25.Final + 4.1.30.Final io.netty netty-common - 4.1.25.Final + 4.1.30.Final io.netty netty-transport - 4.1.25.Final + 4.1.30.Final io.netty netty-handler - 4.1.25.Final + 4.1.30.Final io.netty netty-codec-http - 4.1.25.Final + 4.1.30.Final io.netty netty-codec - 4.1.25.Final + 4.1.30.Final io.netty netty-transport-native-epoll - 4.1.25.Final + 4.1.30.Final @@ -172,7 +172,7 @@ org.redisson redisson - 2.12.0 + 3.8.2 provided diff --git a/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java b/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java index e80ac75..8e286fa 100644 --- a/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java +++ b/src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java @@ -56,7 +56,7 @@ public class RedissonPubSubStore implements PubSubStore { RTopic topic = redissonSub.getTopic(name); int regId = topic.addListener(new MessageListener() { @Override - public void onMessage(String channel, T msg) { + public void onMessage(CharSequence channel, T msg) { if (!nodeId.equals(msg.getNodeId())) { listener.onMessage(msg); }