修改更新设备状态逻辑
This commit is contained in:
@@ -70,7 +70,7 @@ public class FrontHeartBeatConsumer extends EnhanceConsumerMessageHandler<FrontH
|
|||||||
// redisUtil.saveByKeyWithExpire(RedisKeyPrefix.HEART_BEAT.concat(message.getKey()), MessageStatus.BEING_PROCESSED, 30L);
|
// redisUtil.saveByKeyWithExpire(RedisKeyPrefix.HEART_BEAT.concat(message.getKey()), MessageStatus.BEING_PROCESSED, 30L);
|
||||||
// return false;
|
// return false;
|
||||||
// }
|
// }
|
||||||
return true;
|
return false;
|
||||||
}
|
}
|
||||||
/**
|
/**
|
||||||
* 消费成功,缓存到redis72小时,避免重复消费
|
* 消费成功,缓存到redis72小时,避免重复消费
|
||||||
|
|||||||
Reference in New Issue
Block a user