diff options
-rw-r--r-- | client/src/com/vaadin/client/communication/AtmospherePushConnection.java | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/client/src/com/vaadin/client/communication/AtmospherePushConnection.java b/client/src/com/vaadin/client/communication/AtmospherePushConnection.java index e42f91ea67..bc7e0b3fd2 100644 --- a/client/src/com/vaadin/client/communication/AtmospherePushConnection.java +++ b/client/src/com/vaadin/client/communication/AtmospherePushConnection.java @@ -220,14 +220,13 @@ public class AtmospherePushConnection implements PushConnection { VConsole.log("Push connection established using " + transport); - for (String message : messageQueue) { - push(message); - } - messageQueue.clear(); - switch (state) { case CONNECT_PENDING: state = State.CONNECTED; + for (String message : messageQueue) { + push(message); + } + messageQueue.clear(); break; case DISCONNECT_PENDING: // Set state to connected to make disconnect close the connection |