mqtt消费者改版

device-api-service/src/main/java/com/xy/consumer/connected/ConnectedConsumer.java

@@ -2,7 +2,7 @@ package com.xy.consumer.connected;
 
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
-import com.xy.annotate.MqttConsumerConfigure;
+import com.xy.annotate.MqttConsumerAsyn;
 import com.xy.config.DeviceThreadPoolConfig;
 import com.xy.consumer.MqttConsumer;
 import com.xy.device.EnumDeviceOnlineStatus;
@@ -26,7 +26,7 @@ import org.springframework.stereotype.Service;
 @Slf4j
 @Service
 @AllArgsConstructor
-@MqttConsumerConfigure(threadPoll = DeviceThreadPoolConfig.DEVICE_NETWORK_POLL, isFailSaveEs = false)
+@MqttConsumerAsyn(value = DeviceThreadPoolConfig.DEVICE_NETWORK_POLL, isFailSaveEs = false)
 public class ConnectedConsumer implements MqttConsumer {
 
     private DeviceStatusServiceImpl deviceStatusService;

device-api-service/src/main/java/com/xy/consumer/data/DataConsumer.java

@@ -2,7 +2,7 @@ package com.xy.consumer.data;
 
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
-import com.xy.annotate.MqttConsumerConfigure;
+import com.xy.annotate.MqttConsumerAsyn;
 import com.xy.config.DeviceThreadPoolConfig;
 import com.xy.consumer.MqttConsumer;
 import com.xy.dto.DataMqttVo;
@@ -27,7 +27,7 @@ import java.util.List;
 @Slf4j
 @Service
 @AllArgsConstructor
-@MqttConsumerConfigure(threadPoll = DeviceThreadPoolConfig.DEVICE_DATA_POLL)
+@MqttConsumerAsyn(DeviceThreadPoolConfig.DEVICE_DATA_POLL)
 public class DataConsumer implements MqttConsumer {
 
     private DeviceDataServiceImpl deviceDataService;

device-api-service/src/main/java/com/xy/consumer/disconnect/DisconnectedConsumer.java

@@ -1,6 +1,6 @@
 package com.xy.consumer.disconnect;
 
-import com.xy.annotate.MqttConsumerConfigure;
+import com.xy.annotate.MqttConsumerAsyn;
 import com.xy.config.DeviceThreadPoolConfig;
 import com.xy.consumer.MqttConsumer;
 import com.xy.consumer.connected.ConnectedConsumer;
@@ -21,7 +21,7 @@ import org.springframework.stereotype.Service;
 @Slf4j
 @Service
 @AllArgsConstructor
-@MqttConsumerConfigure(threadPoll = DeviceThreadPoolConfig.DEVICE_NETWORK_POLL, isFailSaveEs = false)
+@MqttConsumerAsyn(value = DeviceThreadPoolConfig.DEVICE_NETWORK_POLL, isFailSaveEs = false)
 public class DisconnectedConsumer implements MqttConsumer {
 
     private ConnectedConsumer connectedConsumer;