From 3c88c7d35f11ffb4fb15a6693d0e9a6215f85f24 Mon Sep 17 00:00:00 2001
From: jianjun <jianjun4833@163.com>
Date: Fri, 30 Apr 2021 17:24:57 +0800
Subject: [PATCH] =?UTF-8?q?mq=E6=B3=A8=E5=86=8C=E4=BB=A3=E7=A0=81=E8=B0=83?=
 =?UTF-8?q?=E6=95=B4-=E6=9C=AC=E5=9C=B0=E4=B8=8D=E6=B3=A8=E5=86=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/commons/rocketmq/register/MQConsumerRegister.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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