diff --git a/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java b/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java index 96eed79..9670c19 100644 --- a/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java +++ b/system/mqtt-xf-receiver/src/main/java/org/dromara/mica/mqtt/server/listener/MqttConnectStatusListener2.java @@ -29,15 +29,12 @@ public class MqttConnectStatusListener2 implements IMqttConnectStatusListener { @Override public void online(ChannelContext context, String clientId, String username) { //设备上线不做任何处理,只有心跳报文做处理 - log.info("online-context: {}", context); log.info("设备:{}上线", clientId); } @Override @Transactional(rollbackFor = Exception.class) public void offline(ChannelContext context, String clientId, String username, String reason) { - log.info("offline-context: {}", context); - redisService.deleteObject(CacheConstants.EQUIPMENT_HEARTBEAT + clientId); log.info("设备:{}离线,offline reason:{}.", clientId, reason); } } diff --git a/system/mqtt-xf-receiver/src/main/resources/application.yml b/system/mqtt-xf-receiver/src/main/resources/application.yml index 4ad0c08..caf558c 100644 --- a/system/mqtt-xf-receiver/src/main/resources/application.yml +++ b/system/mqtt-xf-receiver/src/main/resources/application.yml @@ -6,8 +6,8 @@ spring: name: mica-mqtt-server # 环境 dev|test|prod profiles: - active: dev -# active: prod +# active: dev + active: prod messages: encoding: UTF-8 basename: i18n/messages diff --git a/system/pom.xml b/system/pom.xml index 3b1a4bb..726cad1 100644 --- a/system/pom.xml +++ b/system/pom.xml @@ -23,6 +23,10 @@ 2.13.2 + + mqtt-xf-receiver + +