diff --git a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/register/MQConsumerRegister.java b/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/register/MQConsumerRegister.java
index f7e104f112..4c883e74a7 100644
--- a/epmet-commons/epmet-commons-rocketmq/src/main/java/com/epmet/commons/rocketmq/register/MQConsumerRegister.java
+++ b/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());