|
|
@ -52,7 +52,7 @@ public class RedissonPubSubStore implements PubSubStore { |
|
|
|
@Override |
|
|
|
public <T extends PubSubMessage> void subscribe(com.corundumstudio.socketio.store.pubsub.PubSubType type, final PubSubListener<T> listener, Class<T> clazz) { |
|
|
|
String name = type.toString(); |
|
|
|
RTopic<T> topic = redissonSub.getTopic(name); |
|
|
|
RTopic<T> topic = redissonSub.getTopic(name); |
|
|
|
int regId = topic.addListener(new MessageListener<T>() { |
|
|
|
@Override |
|
|
|
public void onMessage(String channel, T msg) { |
|
|
@ -75,7 +75,7 @@ public class RedissonPubSubStore implements PubSubStore { |
|
|
|
|
|
|
|
@Override |
|
|
|
public void unsubscribe(com.corundumstudio.socketio.store.pubsub.PubSubType type) { |
|
|
|
String name = type.toString(); |
|
|
|
String name = type.toString(); |
|
|
|
Queue<Integer> regIds = map.remove(name); |
|
|
|
RTopic<Object> topic = redissonSub.getTopic(name); |
|
|
|
for (Integer id : regIds) { |
|
|
|