|
@@ -36,7 +36,6 @@ public class ChatMessageListener implements MessageListener {
|
|
|
String value = valueSerializer.deserialize(message.getBody());
|
|
|
|
|
|
if (StringUtils.isNotBlank(value)) {
|
|
|
- System.err.println(value);
|
|
|
log.info("监听集群websocket消息--- {}", value);
|
|
|
//集群模式 推送消息
|
|
|
ObjectMapper mapper = new ObjectMapper();
|