处理模板

src/main/java/com/unissoft/mqConsumer/TeDataConsumer.java

@@ -20,13 +20,22 @@ import org.springframework.stereotype.Service;
  */
 @Slf4j
 @Component
-@RocketMQMessageListener(topic = "TOPIC_LOCAL",consumerGroup = "${rocketmq.consumer.group}",selectorExpression = "teData")
-public class TeDataConsumer implements RocketMQListener<TeData> {
+public class TeDataConsumer{
 
-    @Override
-    public void onMessage(TeData s) {
-        System.out.println("接收到的消息"+s.toString());
+    @Component
+    @RocketMQMessageListener(topic = "TOPIC_LOCAL",consumerGroup = "${rocketmq.consumer.group}",selectorExpression = "TD_SAVE")
+    public class TDSave implements RocketMQListener<TeData>{
+        /**
+         * 新增tedata
+         * @param teData 接收到的数据
+         */
+        @Override
+        public void onMessage(TeData teData) {
+            
+            System.out.println("接收到的消息"+teData.toString());
+        }
     }
+
 //
 //    // topic需要和生产者的topic一致，consumerGroup属性是必须指定的，内容可以随意
 //    // selectorExpression的意思指的就是tag，默认为“*”，不设置的话会监听所有消息