【feat】 消息成功确认

huimv-eartag2-platform/huimv-eartag2-input/src/main/java/com/huimv/eartag2/server/MsgSendConfirmCallBack.java

@@ -1,20 +1,20 @@
-package com.huimv.eartag2.server;
-
-import com.sun.istack.Nullable;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.amqp.rabbit.connection.CorrelationData;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
-
-@Slf4j
-public class MsgSendConfirmCallBack implements RabbitTemplate.ConfirmCallback {
-    @Override
-    public void confirm(@Nullable CorrelationData correlationData, boolean ack, @Nullable String cause) {
-        log.info("MsgSendConfirmCallBack , 回调id: {}", correlationData);
-
-        if(ack) {
-            log.info("消息发送成功");
-        } else {
-            log.info("消息发送失败: {}", cause);
-        }
-    }
-}
+//package com.huimv.eartag2.server;
+//
+//import com.sun.istack.Nullable;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.amqp.rabbit.connection.CorrelationData;
+//import org.springframework.amqp.rabbit.core.RabbitTemplate;
+//
+//@Slf4j
+//public class MsgSendConfirmCallBack implements RabbitTemplate.ConfirmCallback {
+//    @Override
+//    public void confirm(@Nullable CorrelationData correlationData, boolean ack, @Nullable String cause) {
+//        log.info("MsgSendConfirmCallBack , 回调id: {}", correlationData);
+//
+//        if(ack) {
+//            log.info("消息发送成功");
+//        } else {
+//            log.info("消息发送失败: {}", cause);
+//        }
+//    }
+//}

huimv-eartag2-platform/huimv-eartag2-input/src/main/java/com/huimv/eartag2/service/impl/DataServiceImpl.java

@@ -8,7 +8,7 @@ import com.huimv.eartag2.common.mq.Const;
 import com.huimv.eartag2.common.utils.BizConst;
 import com.huimv.eartag2.common.utils.FileUtil;
 import com.huimv.eartag2.producer.Producer;
-import com.huimv.eartag2.server.MsgSendConfirmCallBack;
+//import com.huimv.eartag2.server.MsgSendConfirmCallBack;
 import com.huimv.eartag2.service.ICacheService;
 import com.huimv.eartag2.service.IDataService;
 import com.huimv.eartag2.service.IDeviceService;
@@ -292,17 +292,17 @@ public class DataServiceImpl implements IDataService {
 
     @Override
     public void sendEartagMQ(Map map) throws IOException, ParseException {
-        try {
-            rabbitTemplate.setConfirmCallback(new MsgSendConfirmCallBack());
-
-            CorrelationData correlationData = new CorrelationData();
-            log.info("开始发送消息");
-            correlationData.setId("100");
+//        try {
+//            rabbitTemplate.setConfirmCallback(new MsgSendConfirmCallBack());
+//
+//            CorrelationData correlationData = new CorrelationData();
+//            log.info("开始发送消息");
+//            correlationData.setId("100");
             //发送到耳标处理消息队列
             rabbitTemplate.convertAndSend(Const.EXCHANGE_ASK_EARTAG, Const.ROUTING_KEY_ASK_EARTAG, map);
-        } catch (AmqpTimeoutException e) {
-            log.error("met timeout exception: ", e);
-        }
+//        } catch (AmqpTimeoutException e) {
+//            log.error("met timeout exception: ", e);
+//        }
     }