fix: 解决gamma自动处理推送分析进度会出现userid=null的问题
This commit is contained in:
parent
4d47579788
commit
c9cb095a9b
|
@ -1,6 +1,7 @@
|
||||||
package org.jeecg.modules.message.handle;
|
package org.jeecg.modules.message.handle;
|
||||||
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.apache.commons.lang3.ObjectUtils;
|
||||||
import org.jeecg.common.base.BaseMap;
|
import org.jeecg.common.base.BaseMap;
|
||||||
import org.jeecg.common.constant.WebSocketHandlerConst;
|
import org.jeecg.common.constant.WebSocketHandlerConst;
|
||||||
import org.jeecg.common.modules.redis.listener.JeecgRedisListener;
|
import org.jeecg.common.modules.redis.listener.JeecgRedisListener;
|
||||||
|
@ -24,6 +25,9 @@ public class AnalysisHandler implements JeecgRedisListener {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onMessage(BaseMap message) {
|
public void onMessage(BaseMap message) {
|
||||||
|
if (ObjectUtils.isEmpty(message.get("userId"))) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
webSocket.sendMessage(message.get("userId").toString(), message.get("message"));
|
webSocket.sendMessage(message.get("userId").toString(), message.get("message"));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user