diff --git a/src/main/java/earth/krakatao/SocketClient.java b/src/main/java/earth/krakatao/SocketClient.java
index b5ea718..bbc8177 100644
--- a/src/main/java/earth/krakatao/SocketClient.java
+++ b/src/main/java/earth/krakatao/SocketClient.java
@@ -59,7 +59,8 @@ public class SocketClient extends WebSocketClient {
       return;
     }
 
-    if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.REPLY.getStatus()
+    // response to the user that this message cmdID is already in the queue
+    if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()
         && this.kraProtocol.getCmdIDs().contains(kraProtocolMessage.getCmdID())) {
       // TODO: uuid
       kraProtocolMessage = new KraSocketClientProtocolMessage(
@@ -68,19 +69,10 @@ public class SocketClient extends WebSocketClient {
               ? kraProtocolMessage.getStatus() : 0, 0,
           "bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb", (short) kraProtocolMessage.getCmdNumber(), "");
 
-      if (this.kraProtocol.getCmdIDs().contains(kraProtocolMessage.getCmdID())) {
-        this.kraProtocol.getCmdIDs().remove(kraProtocolMessage.getCmdID());
-      }
-
       this.SendMessage(kraProtocolMessage);
       return;
     }
 
-    if (kraProtocolMessage.getStatus() == KraSocketClientProtocolStatus.GET.getStatus()
-        && this.kraProtocol.getCmdIDs().contains(kraProtocolMessage.getCmdID())) {
-      this.kraProtocol.getCmdIDs().remove(kraProtocolMessage.getCmdID());
-    }
-
     this.kraSocketClientEventInitiater.callOnMessage(kraProtocolMessage);
   }