Browse Source

注释rocketmq的代码

houweiyu 4 years ago
parent
commit
f860beebd8

+ 5 - 1
src/main/java/fcb/project/manager/core/rocketmqConsumer/AsyncWriteDbConsumerListener.java

@@ -1,3 +1,4 @@
+/*
 package fcb.project.manager.core.rocketmqConsumer;
 
 import com.alibaba.fastjson.JSON;
@@ -22,11 +23,13 @@ import org.springframework.util.CollectionUtils;
 import java.time.LocalDateTime;
 import java.util.List;
 
+*/
 /**
  * 2 * @Author: Abner
  * 3 * @Date: 2021/1/12 14:22
  * 4
- */
+ *//*
+
 
 @RocketMQMessageListener(topic = "abner-test", consumerGroup = "rocketmq-cluster5",
         selectorExpression = "*")
@@ -160,3 +163,4 @@ public class AsyncWriteDbConsumerListener implements RocketMQListener<String> {
         }
     }
 }
+*/