From 51af3e4e7c5fb612576b98fd6407f6b65859f374 Mon Sep 17 00:00:00 2001
From: Van333 <van666666@foxmail.com>
Date: 星期三, 16 十一月 2022 15:58:06 +0800
Subject: [PATCH] 区分消息订阅类型，新增上下线监听，修复定时帧缺少CRC32，替换设备在线状态查询方法
---
ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/MsgMqttCallBack.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/DefaultMqttCallBack.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/MsgMqttCallBack.java
similarity index 94%
rename from ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/DefaultMqttCallBack.java
rename to ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/MsgMqttCallBack.java
index d156121..82fc40f 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/DefaultMqttCallBack.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/localMQTT/callback/MsgMqttCallBack.java
@@ -31,8 +31,8 @@
* @date 2022/11/9 16:24
*/
@Slf4j
-@Component("default")
-public class DefaultMqttCallBack extends AbsMqttCallBack {
+@Component("java_server_msg")
+public class MsgMqttCallBack extends AbsMqttCallBack {
private static final String localMqttConnectTypeOfSync = "1";
@@ -44,7 +44,7 @@
protected final static ExecutorService EXECUTOR_SERVICE = new ThreadPoolExecutor(
Runtime.getRuntime().availableProcessors(),
Runtime.getRuntime().availableProcessors() * 2, 60, TimeUnit.SECONDS,
- new LinkedBlockingQueue<>(50000), new DefaultMqttCallBack.NameTreadFactory());
+ new LinkedBlockingQueue<>(50000), new MsgMqttCallBack.NameTreadFactory());
static class NameTreadFactory implements ThreadFactory {
@@ -60,7 +60,7 @@
protected void handleReceiveMessage(String topic, String message) {
EXECUTOR_SERVICE.submit(() -> processMessage(topic,message));
- log.info("鎺ユ敹鍒版秷鎭�---DefaultCallBack:topic={},message={}", topic, message);
+ log.info("鎺ユ敹鍒版秷鎭�---MsgMqttCallBack:topic={},message={}", topic, message);
}
--
Gitblit v1.9.3