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());