|
|
@@ -44,7 +44,8 @@ public class DefaultMessageListener implements PatternMessageListener<TopicMessa
|
|
|
} catch (JsonProcessingException e) {
|
|
|
log.error("ws消息订阅,解析失败,message:【】", JSONUtil.toJsonStr(msg));
|
|
|
}
|
|
|
- }else {
|
|
|
+ }
|
|
|
+ else {
|
|
|
channelContext.setClosed(true);
|
|
|
rPatternTopic.removeListener(this);
|
|
|
Tio.remove(channelContext,"通道已关闭,移除该通道");
|