0827-稳定版-完善(发送消息时可以不用wellList)1

src/main/java/com/gct/tools/etlcamelhuge/MQ/DefaultMsgSendSuccessCallBack.java

@@ -19,7 +19,7 @@ public class DefaultMsgSendSuccessCallBack implements SendSuccessCallBack {
     public static AtomicInteger count =new AtomicInteger(0);
     @Override
     public void accept(SendResult sendResult) {
-        System.out.println("send success= "+count.incrementAndGet());
+        //System.out.println("send success= "+count.incrementAndGet());
         //log.info("send msg success,msg:{}", sendResult.getMsgId());
     }
 }

src/main/java/com/gct/tools/etlcamelhuge/controller/GtController.java

@@ -86,7 +86,7 @@ public class GtController {
                 sgt = "0,0,0,0,0,0,0,0,0,0";
             }
             DiagnoseMsg diagnoseMsg = new DiagnoseMsg(wellId, wellName, orgId, prodDate, sgt, LocalDateTime.now().toString(), strokeLength, strokeFrequency);
-            //producer.send((MessageBody) diagnoseMsg);
+            producer.send((MessageBody) diagnoseMsg);
             sumData++;
         }
         return sumData;