Commit cef69400 authored by 赵啸非's avatar 赵啸非

修改日志记录

parent 67afb888
......@@ -66,6 +66,11 @@ public class DirectDynamicListener implements MessageListener {
String deviceCode = queueMsg.getHeaders().getData().get(DEVICECODE);
String messageType = queueMsg.getHeaders().getData().get(MESSAGETYPE);
try {
if(ObjectUtils.isEmpty(deviceCode)){
log.info("onMessage deviceCode is null,receive data:{}",data);
return;
}
DeviceEntity deviceEntity = deviceService.getExtCache(deviceCode);
if (!ObjectUtils.isEmpty(deviceEntity)) {
cacheService.set(RedisKey.KEY_DEVICE_ONLINE_CACHE + deviceEntity.getDeviceCode(), "", GlobalSysInfo.getParamIntValue(Constant.HEARTBEAT_TIMEOUT, 120));
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment