|
|
@@ -112,9 +112,9 @@ public class ImUtils {
|
|
|
.publishAsync( TopicMessage.of(roomMsg,param,pubMsgInfo.getKey()))
|
|
|
.whenComplete((r,e)->{
|
|
|
if(e==null){
|
|
|
- log.info("发送聊天室消息{}成功",JSONUtil.toJsonStr(roomMsg));
|
|
|
+ log.info("topic:{},发送聊天室消息{}成功",topic,JSONUtil.toJsonStr(roomMsg));
|
|
|
}else{
|
|
|
- log.error("发送聊天室消息{}失败,",JSONUtil.toJsonStr(roomMsg),e);
|
|
|
+ log.error("topic:{},发送聊天室消息{}失败,",topic,JSONUtil.toJsonStr(roomMsg),e);
|
|
|
}
|
|
|
if(channelContext!=null){
|
|
|
Tio.send(channelContext, WsResponse.fromText(JSONUtil.toJsonStr(
|