summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--client/src/com/vaadin/client/communication/AtmospherePushConnection.java9
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