rocketMQ优化

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

@@ -46,15 +46,19 @@ import java.util.List;
 public class RocketMQAspect
 {
     private final ExpressionParser parser = new SpelExpressionParser();
+
+    @Autowired
+    @Lazy
+    DefaultMQProducer defaultMQProducer;
+
+    @Value("${r'${ibiz.rocketmq.topic:default}'}")
+    private String topic;
+
     <#list sys.getAllPSDataEntities() as dataEntity>
         <#if dataEntity.getAllPSDEDataSyncs?? && dataEntity.getAllPSDEDataSyncs()??>
             <#list dataEntity.getAllPSDEDataSyncs() as dataSync>
                 <#if dataSync.getOutPSSysDataSyncAgent?? && dataSync.getOutPSSysDataSyncAgent()??>
                     <#assign producer=dataEntity.codeName+dataSync.codeName>
-    @Autowired
-    @Lazy
-    DefaultMQProducer defaultMQProducer;
-
     @AfterReturning(value = "(execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.create*(..))||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.update*(..))||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.save*(..)) ||execution(* ${pub.getPKGCodeName()}.core.*.service.*${dataEntity.codeName}*.remove*(..))) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.create*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.update*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.save*(..)) && !execution(* ${pub.getPKGCodeName()}.core.es.service.*.remove*(..))")
     @Async
     public void ${srfmethodname(producer)}(JoinPoint point) {
@@ -62,7 +66,7 @@ public class RocketMQAspect
         <#assign actionName=srfmethodname(dataSync.getOutTestPSDEAction().codeName)>
         outputAction(point, "${actionName}");
         </#if>
-        sendMsg("default", "${dataSync.codeName?lower_case}", getEntity(point));
+        sendMsg(topic, "${dataSync.codeName?lower_case}", getEntity(point));
     }
                 </#if>
             </#list>