From 68389b172fa53f85ea6d3ed8dfaa17cad6483378 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Sat, 28 Jun 2014 20:57:14 +0400
Subject: [PATCH] Transport upgrade fixed. #123

---
 .../com/corundumstudio/socketio/handler/ClientHead.java    | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/corundumstudio/socketio/handler/ClientHead.java b/src/main/java/com/corundumstudio/socketio/handler/ClientHead.java
index 06fbd5f..e388863 100644
--- a/src/main/java/com/corundumstudio/socketio/handler/ClientHead.java
+++ b/src/main/java/com/corundumstudio/socketio/handler/ClientHead.java
@@ -241,14 +241,13 @@ public class ClientHead {
 
                 Queue<Packet> queue = entry.getValue().getPacketsQueue();
                 state.setPacketsQueue(queue);
-                entry.getValue().setPacketsQueue(new ConcurrentLinkedQueue<Packet>());
 
                 sendPackets(currentTransport, state.getChannel());
+                this.currentTransport = currentTransport;
+                log.debug("Transport upgraded to: {} for: {}", currentTransport, sessionId);
+                break;
             }
         }
-        this.currentTransport = currentTransport;
-
-        log.debug("Transport upgraded to: {} for: {}", currentTransport, sessionId);
     }
 
     public Transport getCurrentTransport() {