Browse Source

Redisson compatibility fixed #602

master
Nikita 7 years ago
parent
commit
809931707c
  1. 16
      pom.xml
  2. 2
      src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java

16
pom.xml

@ -85,37 +85,37 @@
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-buffer</artifactId>
<version>4.1.25.Final</version>
<version>4.1.30.Final</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-common</artifactId>
<version>4.1.25.Final</version>
<version>4.1.30.Final</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-transport</artifactId>
<version>4.1.25.Final</version>
<version>4.1.30.Final</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-handler</artifactId>
<version>4.1.25.Final</version>
<version>4.1.30.Final</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-codec-http</artifactId>
<version>4.1.25.Final</version>
<version>4.1.30.Final</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-codec</artifactId>
<version>4.1.25.Final</version>
<version>4.1.30.Final</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-transport-native-epoll</artifactId>
<version>4.1.25.Final</version>
<version>4.1.30.Final</version>
</dependency>
<dependency>
@ -172,7 +172,7 @@
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>2.12.0</version>
<version>3.8.2</version>
<scope>provided</scope>
</dependency>
<dependency>

2
src/main/java/com/corundumstudio/socketio/store/RedissonPubSubStore.java

@ -56,7 +56,7 @@ public class RedissonPubSubStore implements PubSubStore {
RTopic<T> topic = redissonSub.getTopic(name);
int regId = topic.addListener(new MessageListener<T>() {
@Override
public void onMessage(String channel, T msg) {
public void onMessage(CharSequence channel, T msg) {
if (!nodeId.equals(msg.getNodeId())) {
listener.onMessage(msg);
}

Loading…
Cancel
Save