消息配置

SLN/%PUBPRJ%-core/src/main/java/%SYS_PKGPATH%/core/util/config/RocketMQConsumer.java.ftl

@@ -48,13 +48,13 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 @ConditionalOnExpression("${r'${rocketmq.consumer.isOnOff:'+"'"+mqServer+"'"+"}.equals('on')"}")
 public class RocketMQConsumer {
 
-    @Value("${r'${rocketmq.producer.groupName:default}'}")
+    @Value("${r'${rocketmq.consumer.groupName:default}'}")
     private String groupName;
 
-    @Value("${r'${rocketmq.topic:default}'}")
+    @Value("${r'${rocketmq.consumer.topic:default}'}")
     private String topic;
 
-    @Value("${r'${rocketmq.producer.namesrvAddr:127.0.0.1:9876}'}")
+    @Value("${r'${rocketmq.consumer.namesrvAddr:127.0.0.1:9876}'}")
     private String namesrvAddr;
 
     @Value("${r'${rocketmq.consumer.consumeThreadMin:1}'}")

SLN/%PUBPRJ%-util/src/main/java/%SYS_PKGPATH%/util/aspect/RocketMQAspect.java.ftl

@@ -70,7 +70,7 @@ public class RocketMQAspect
     @Lazy
     DefaultMQProducer defaultMQProducer;
 
-    @Value("${r'${rocketmq.topic:default}'}")
+    @Value("${r'${rocketmq.producer.topic:default}'}")
     private String topic;
 
     <#list sys.getAllPSDataEntities() as dataEntity>