|
@@ -26,7 +26,7 @@ public class SubMsgRequestHandler implements IMsgRequestHandler {
|
|
|
private final RedissonClient redissonClient;
|
|
private final RedissonClient redissonClient;
|
|
|
@Override
|
|
@Override
|
|
|
public MessagingRequest.Type getType() {
|
|
public MessagingRequest.Type getType() {
|
|
|
- return MessagingRequest.Type.unsub;
|
|
|
|
|
|
|
+ return MessagingRequest.Type.sub;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|