From 081436b99e7ee76b716ba0fc3ff69733ae8067fc Mon Sep 17 00:00:00 2001 From: Nikita Date: Thu, 26 Sep 2013 12:30:22 +0400 Subject: [PATCH] bug with ACK_TIMEOUT cancellation fixed --- src/main/java/com/corundumstudio/socketio/ack/AckManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/corundumstudio/socketio/ack/AckManager.java b/src/main/java/com/corundumstudio/socketio/ack/AckManager.java index eb46556..9b227af 100644 --- a/src/main/java/com/corundumstudio/socketio/ack/AckManager.java +++ b/src/main/java/com/corundumstudio/socketio/ack/AckManager.java @@ -94,7 +94,7 @@ public class AckManager implements Disconnectable { } public void onAck(SocketIOClient client, Packet packet) { - SchedulerKey key = new SchedulerKey(Type.ACK_TIMEOUT, client.getSessionId()); + AckSchedulerKey key = new AckSchedulerKey(Type.ACK_TIMEOUT, client.getSessionId(), packet.getAckId()); scheduler.cancel(key); AckCallback callback = removeCallback(client.getSessionId(), packet.getAckId());