diff --git a/jmqtt-broker/pom.xml b/jmqtt-broker/pom.xml
index bad6d0ada0b07d285abdcfed6dbc054eb0cd1d00..eed6a4f48a5d65eb6cd7e4c52f18d5289ac7aec5 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>
 
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 236037cb86cb4bb1d11487b12ad275b2525851c7..47e3be045dbf4a3d53ff8feaf081627096e5dfbd 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);