消息配置

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

@@ -19,8 +19,8 @@ TARGET=PSSYSTEM
     <#if sys.getAllPSDevSlnMSDepAPIs()??>
         <#list sys.getAllPSDevSlnMSDepAPIs() as depSysApi>
             <#if depSysApi.getPSDCMSPlatform()?? >
-                <#if depSysApi.getUserParam("ibiz.rocketmq.consumer.namesrvAddr","")??>
-                    <#assign mqServerAddress = depSysApi.getUserParam("ibiz.rocketmq.consumer.namesrvAddr","")>
+                <#if depSysApi.getUserParam("rocketmq.consumer.namesrvAddr","")??>
+                    <#assign mqServerAddress = depSysApi.getUserParam("rocketmq.consumer.namesrvAddr","")>
                 </#if>
             </#if>
         </#list>

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

@@ -18,8 +18,8 @@ TARGET=PSSYSTEM
     <#if sys.getAllPSDevSlnMSDepAPIs()??>
         <#list sys.getAllPSDevSlnMSDepAPIs() as depSysApi>
             <#if depSysApi.getPSDCMSPlatform()?? >
-                <#if depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")??>
-                    <#assign mqServerAddress = depSysApi.getUserParam("ibiz.rocketmq.producer.namesrvAddr","")>
+                <#if depSysApi.getUserParam("rocketmq.producer.namesrvAddr","")??>
+                    <#assign mqServerAddress = depSysApi.getUserParam("rocketmq.producer.namesrvAddr","")>
                 </#if>
             </#if>
         </#list>
@@ -61,7 +61,7 @@ import java.util.List;
 @Slf4j
 @Aspect
 @Component
-@ConditionalOnExpression("${r'${ibiz.rocketmq.producer.isOnOff:'+"'"+mqServer+"'"+"}.equals('on')"}")
+@ConditionalOnExpression("${r'${rocketmq.producer.isOnOff:'+"'"+mqServer+"'"+"}.equals('on')"}")
 public class RocketMQAspect
 {
     private final ExpressionParser parser = new SpelExpressionParser();
@@ -70,7 +70,7 @@ public class RocketMQAspect
     @Lazy
     DefaultMQProducer defaultMQProducer;
 
-    @Value("${r'${ibiz.rocketmq.topic:default}'}")
+    @Value("${r'${rocketmq.topic:default}'}")
     private String topic;
 
     <#list sys.getAllPSDataEntities() as dataEntity>