mq消息生产

pom.xml

@@ -107,13 +107,17 @@
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-http</artifactId>
         </dependency>
-
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-core</artifactId>
             <version>2.12.3</version>
         </dependency>
         <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>2.2.0</version>
+        </dependency>
+        <dependency>
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-jackson</artifactId>
         </dependency>

src/main/java/com/gct/tools/etlcamelhuge/entity/MQDiagnoseMsg.java

@@ -0,0 +1,14 @@
+package com.gct.tools.etlcamelhuge.entity;
+
+import lombok.Data;
+
+@Data
+public class MQDiagnoseMsg {
+
+    private String well_id ;
+    private String well_name;
+    private String org_id;
+    private String pord_date;//创建时间
+    private String sgt;
+    private String rcv_date;//采集时间
+}