mq注册代码调整暂时恢复

epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/register/MQConsumerRegister.java

@@ -34,7 +34,7 @@ public abstract class MQConsumerRegister {
         ConsumerConfigProperties consumerProperty = getConsumerProperty();
         log.info("registerAllListeners consumers:{} success", consumerProperty);
         //本地环境不注册
-        if (!"local".equals(env)) {
+        //if (!"local".equals(env)) {
             try {
                 // 实例化消费者
                 DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerProperty.getConsumerGroup());
@@ -55,7 +55,7 @@ public abstract class MQConsumerRegister {
                 log.info("registerMQListener exception", e);
             }
 
-        }
+        //}
 
     }
 

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/ProjectChangedCustomListener.java

@@ -1,11 +1,7 @@
 package com.epmet.mq;
 
 import com.alibaba.fastjson.JSON;
-import com.epmet.commons.rocketmq.constants.ConsomerGroupConstants;
-import com.epmet.commons.rocketmq.constants.TopicConstants;
 import com.epmet.commons.rocketmq.messages.ProjectChangedMQMsg;
-import com.epmet.commons.rocketmq.register.ConsumerConfigProperties;
-import com.epmet.commons.rocketmq.register.MQConsumerRegister;
 import com.epmet.commons.tools.distributedlock.DistributedLock;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.utils.SpringContextUtils;
@@ -22,7 +18,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import org.redisson.api.RLock;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
 
 import javax.annotation.PreDestroy;
 import java.util.Date;
@@ -39,8 +34,8 @@ import java.util.stream.Collectors;
  * @date 2021.03.03 16:10
 */
 @Slf4j
-@Component
-public class ProjectChangedCustomListener extends MQConsumerRegister implements MessageListenerConcurrently {
+//@Component
+public class ProjectChangedCustomListener implements MessageListenerConcurrently {
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
@@ -122,7 +117,7 @@ public class ProjectChangedCustomListener extends MQConsumerRegister implements
 
     }
 
-    @Override
+    /*@Override
     public ConsumerConfigProperties getConsumerProperty() {
         ConsumerConfigProperties configProperties = new ConsumerConfigProperties();
         configProperties.setConsumerGroup(ConsomerGroupConstants.PROJECT_CHANGED_COMPONENTS_GROUP);
@@ -130,5 +125,5 @@ public class ProjectChangedCustomListener extends MQConsumerRegister implements
         configProperties.setTag("*");
         configProperties.setConsumerListener(this);
         return configProperties;
-    }
+    }*/
 }

epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/mq/RocketMQConsumerRegister.java

@@ -10,12 +10,12 @@ import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
 import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
 
 @Slf4j
-//@Component
-//@Order(value = 111)
+@Component
 public class RocketMQConsumerRegister {
     @Value("${spring.profiles.active}")
     private String env;

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/mq/RocketMQConsumerRegister.java

@@ -9,10 +9,11 @@ import org.apache.rocketmq.client.consumer.listener.MessageListener;
 import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
 
-//@Component
+@Component
 public class RocketMQConsumerRegister {
     @Value("${spring.profiles.active}")
     private String env;

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/mq/listener/InitCustomerOrgRolesListener.java

@@ -1,11 +1,7 @@
 package com.epmet.mq.listener;
 
 import com.alibaba.fastjson.JSON;
-import com.epmet.commons.rocketmq.constants.ConsomerGroupConstants;
-import com.epmet.commons.rocketmq.constants.TopicConstants;
 import com.epmet.commons.rocketmq.messages.InitCustomerMQMsg;
-import com.epmet.commons.rocketmq.register.ConsumerConfigProperties;
-import com.epmet.commons.rocketmq.register.MQConsumerRegister;
 import com.epmet.commons.tools.distributedlock.DistributedLock;
 import com.epmet.commons.tools.exception.ExceptionUtils;
 import com.epmet.commons.tools.exception.RenException;
@@ -22,7 +18,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import org.redisson.api.RLock;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
 
 import java.util.List;
 import java.util.concurrent.TimeUnit;
@@ -33,8 +28,8 @@ import java.util.concurrent.TimeUnit;
  * @return
  * @date 2021.03.03 16:10
  */
-@Component
-public class InitCustomerOrgRolesListener extends MQConsumerRegister implements MessageListenerConcurrently {
+//@Component
+public class InitCustomerOrgRolesListener implements MessageListenerConcurrently {
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
@@ -106,7 +101,7 @@ public class InitCustomerOrgRolesListener extends MQConsumerRegister implements
         return agencyAndStaff;
     }
 
-    @Override
+   /* @Override
     public ConsumerConfigProperties getConsumerProperty() {
         ConsumerConfigProperties configProperties = new ConsumerConfigProperties();
         configProperties.setConsumerGroup(ConsomerGroupConstants.INIT_CUSTOMER_ORG_ROLES_GROUP);
@@ -114,5 +109,5 @@ public class InitCustomerOrgRolesListener extends MQConsumerRegister implements
         configProperties.setTag("*");
         configProperties.setConsumerListener(this);
         return configProperties;
-    }
+    }*/
 }

epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/mq/RocketMQConsumerRegister.java

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
 
-//@Component
+@Component
 public class RocketMQConsumerRegister {
 
     @Value("${rocketmq.name-server}")

epmet-module/oper-customize/oper-customize-server/src/main/java/com/epmet/mq/listener/InitCustomerComponentsListener.java

@@ -1,11 +1,7 @@
 package com.epmet.mq.listener;
 
 import com.alibaba.fastjson.JSON;
-import com.epmet.commons.rocketmq.constants.ConsomerGroupConstants;
-import com.epmet.commons.rocketmq.constants.TopicConstants;
 import com.epmet.commons.rocketmq.messages.InitCustomerMQMsg;
-import com.epmet.commons.rocketmq.register.ConsumerConfigProperties;
-import com.epmet.commons.rocketmq.register.MQConsumerRegister;
 import com.epmet.commons.tools.distributedlock.DistributedLock;
 import com.epmet.commons.tools.exception.ExceptionUtils;
 import com.epmet.commons.tools.exception.RenException;
@@ -27,8 +23,8 @@ import java.util.concurrent.TimeUnit;
 /**
  * 监听初始化客户动作，为客户初始化角色列表
  */
-@Component
-public class InitCustomerComponentsListener extends MQConsumerRegister implements MessageListenerConcurrently {
+//@Component
+public class InitCustomerComponentsListener implements MessageListenerConcurrently {
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
@@ -72,7 +68,7 @@ public class InitCustomerComponentsListener extends MQConsumerRegister implement
         }
     }
 
-    @Override
+   /* @Override
     public ConsumerConfigProperties getConsumerProperty() {
         ConsumerConfigProperties configProperties = new ConsumerConfigProperties();
         configProperties.setConsumerGroup(ConsomerGroupConstants.INIT_CUSTOMER_COMPONENTS_GROUP);
@@ -80,5 +76,5 @@ public class InitCustomerComponentsListener extends MQConsumerRegister implement
         configProperties.setTag("*");
         configProperties.setConsumerListener(this);
         return configProperties;
-    }
+    }*/
 }

epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/GroupAchievementCustomListener.java

@@ -1,11 +1,7 @@
 package com.epmet.mq;
 
 import com.alibaba.fastjson.JSON;
-import com.epmet.commons.rocketmq.constants.ConsomerGroupConstants;
-import com.epmet.commons.rocketmq.constants.TopicConstants;
 import com.epmet.commons.rocketmq.messages.GroupAchievementMQMsg;
-import com.epmet.commons.rocketmq.register.ConsumerConfigProperties;
-import com.epmet.commons.rocketmq.register.MQConsumerRegister;
 import com.epmet.commons.tools.distributedlock.DistributedLock;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.utils.SpringContextUtils;
@@ -19,7 +15,6 @@ import org.apache.rocketmq.common.message.MessageExt;
 import org.redisson.api.RLock;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
 
 import java.util.List;
 import java.util.concurrent.TimeUnit;
@@ -31,8 +26,8 @@ import java.util.concurrent.TimeUnit;
  * @date 2021.03.03 16:10
 */
 @Slf4j
-@Component
-public class GroupAchievementCustomListener extends MQConsumerRegister implements MessageListenerConcurrently {
+//@Component
+public class GroupAchievementCustomListener  implements MessageListenerConcurrently {
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
@@ -91,7 +86,7 @@ public class GroupAchievementCustomListener extends MQConsumerRegister implement
 
 
 
-    @Override
+    /*@Override
     public ConsumerConfigProperties getConsumerProperty() {
         ConsumerConfigProperties configProperties = new ConsumerConfigProperties();
         configProperties.setConsumerGroup(ConsomerGroupConstants.GROUP_ACHIEVEMENT_COMPONENTS_GROUP);
@@ -99,5 +94,5 @@ public class GroupAchievementCustomListener extends MQConsumerRegister implement
         configProperties.setTag("*");
         configProperties.setConsumerListener(this);
         return configProperties;
-    }
+    }*/
 }

epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/mq/RocketMQConsumerRegister.java

@@ -9,11 +9,12 @@ import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
 import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.common.protocol.heartbeat.MessageModel;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
 
 import javax.annotation.PostConstruct;
 
 @Slf4j
-//@Component
+@Component
 public class RocketMQConsumerRegister {
     @Value("${spring.profiles.active}")
     private String env;