hrmRocketMq修改成配置

.idea/haojing.iml

@@ -9,7 +9,7 @@
             <entry key="jrebelEnabled" value="false" />
           </map>
         </option>
-        <option name="version" value="7" />
+        <option name="version" value="9" />
       </configuration>
     </facet>
   </component>

src/weaver/interfaces/dito/mq/HrmRocketmqServlet.java

@@ -72,13 +72,21 @@ public class HrmRocketmqServlet extends HttpServlet {
         try {
 //            String consumerGroup = propBean.getUfPropValueStatic("consumerGroup");
 //            bb.writeLog("consumerGroup:" + consumerGroup);
-            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("portal-producer-group_oaweaver2");
+            String hrmConsumerGroup = PropBean.getUfPropValue("hrmConsumerGroup");
+            String hrmConsumerAddr = PropBean.getUfPropValue("hrmConsumerAddr");
+            String hrmInstanceName = PropBean.getUfPropValue("hrmInstanceName");
+            String hrmSubExpr = PropBean.getUfPropValue("hrmSubExpr");
+            String hrmMQAuthID = PropBean.getUfPropValue("hrmMQAuthID");
+            String hrmMQAuthPWD = PropBean.getUfPropValue("hrmMQAuthPWD");
+            String hrmMQClusterName = PropBean.getUfPropValue("hrmMQClusterName");
+            String hrmMQTenantID = PropBean.getUfPropValue("hrmMQTenantID");
+            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(hrmConsumerGroup);
 //            String namesrvAddr = propBean.getUfPropValueStatic("namesrvAddr");
 //            bb.writeLog("namesrvAddr:" + namesrvAddr);
-            consumer.setNamesrvAddr("10.26.3.152:9306;10.26.3.151:9306;10.26.3.150:9306");
+            consumer.setNamesrvAddr(hrmConsumerAddr);
 //            String instanceName = propBean.getUfPropValueStatic("instanceName");
 //            bb.writeLog("instanceName:" + instanceName);
-            consumer.setInstanceName("BD_MD_SUBSCRIBE");
+            consumer.setInstanceName(hrmInstanceName);
             consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
 //            String topic = propBean.getUfPropValueStatic("topic");
 //            String subExpression = propBean.getUfPropValueStatic("subExpression");
@@ -92,11 +100,11 @@ public class HrmRocketmqServlet extends HttpServlet {
 //            bb.writeLog("authpwd:" + authpwd);
 //            bb.writeLog("clustername:" + clustername);
 //            bb.writeLog("tenantid:" + tenantid);
-            consumer.subscribe("BD_MD_SUBSCRIBE", "PC_OA");
+            consumer.subscribe(hrmInstanceName, hrmSubExpr);
-            consumer.setAuthID("DITOMQ_WhaleCloud");
+            consumer.setAuthID(hrmMQAuthID);
-            consumer.setAuthPWD("9oXAWfZ&");
+            consumer.setAuthPWD(hrmMQAuthPWD);
-            consumer.setClusterName("CTGMQ_CO3T");
+            consumer.setClusterName(hrmMQClusterName);
-            consumer.setTenantID("100000");
+            consumer.setTenantID(hrmMQTenantID);
 
             consumer.setConsumeThreadMin(1);
             consumer.setConsumeThreadMax(1);