From cf4566f0fcf65e7a12fb3bb8167e4b3d7eecd355 Mon Sep 17 00:00:00 2001
From: lichunyang <lichunyang321@aliyun.com>
Date: Tue, 18 May 2021 19:21:18 +0800
Subject: [PATCH 1/2] =?UTF-8?q?update=20jmqtt-broker/src/main/java/org/jmq?=
 =?UTF-8?q?tt/broker/processor/dispatcher/EventConsumeHandler.java.=20?=
 =?UTF-8?q?=E4=BF=AE=E6=AD=A3client=E5=AD=98=E5=9C=A8=E7=9A=84=E5=88=A4?=
 =?UTF-8?q?=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../jmqtt/broker/processor/dispatcher/EventConsumeHandler.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/jmqtt-broker/src/main/java/org/jmqtt/broker/processor/dispatcher/EventConsumeHandler.java b/jmqtt-broker/src/main/java/org/jmqtt/broker/processor/dispatcher/EventConsumeHandler.java
index 236037c..47e3be0 100644
--- a/jmqtt-broker/src/main/java/org/jmqtt/broker/processor/dispatcher/EventConsumeHandler.java
+++ b/jmqtt-broker/src/main/java/org/jmqtt/broker/processor/dispatcher/EventConsumeHandler.java
@@ -104,7 +104,7 @@ public class EventConsumeHandler {
             return;
         }
         String clientId = event.getBody();
-        if (ConnectManager.getInstance().containClient(clientId)) {
+        if (!ConnectManager.getInstance().containClient(clientId)) {
             return;
         }
         ClientSession clientSession = ConnectManager.getInstance().getClient(clientId);
-- 
Gitee


From 2814b9fe6fa97d5185bda572b532a11649561014 Mon Sep 17 00:00:00 2001
From: lichunyang <lichunyangly@163.com>
Date: Tue, 18 May 2021 19:36:34 +0800
Subject: [PATCH 2/2] test

---
 jmqtt-broker/pom.xml | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/jmqtt-broker/pom.xml b/jmqtt-broker/pom.xml
index bad6d0a..eed6a4f 100755
--- a/jmqtt-broker/pom.xml
+++ b/jmqtt-broker/pom.xml
@@ -62,11 +62,6 @@
             <groupId>org.apache.logging.log4j</groupId>
             <artifactId>log4j-api</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-        </dependency>
-
 
     </dependencies>
 
-- 
Gitee