diff --git a/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java b/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java index 4533f70..0aa77ba 100644 --- a/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java +++ b/src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java @@ -56,7 +56,7 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac kraSocketClientProtocolMessage.getMessageConsumer().accept(kraProtocolMessage); ProxySystem.getInstance().getKraSocketClientProtocol() - .removeData(kraProtocolMessage.getCmdID()); + .removeMessageFromSendQueue(kraProtocolMessage.getCmdID()); } } @@ -170,7 +170,7 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac .SendMessage(kraSocketClientProtocolMessage); ProxySystem.getInstance().getKraSocketClientProtocol() - .removeData(kraProtocolMessage.getCmdID()); + .removeMessageFromSendQueue(kraProtocolMessage.getCmdID()); System.out.println( "cmdNumber 53874 answered back to uuid:" + kraProtocolMessage.getUuid()