diff options
author | Leif Åstrand <leif@vaadin.com> | 2013-05-03 11:44:11 +0300 |
---|---|---|
committer | Leif Åstrand <leif@vaadin.com> | 2013-05-03 11:44:11 +0300 |
commit | 0f5831df6f2a4bf31d4ca0a45e14662c8d172ef2 (patch) | |
tree | d5705be569cbbcde8561618b5035c1ab4ba9e657 /client | |
parent | fbb0da7b88f1828030e105929ee0fcd9e9dba83b (diff) | |
download | vaadin-framework-0f5831df6f2a4bf31d4ca0a45e14662c8d172ef2.tar.gz vaadin-framework-0f5831df6f2a4bf31d4ca0a45e14662c8d172ef2.zip |
Update state before purging outgoing queue (#11768)
Change-Id: I83ad088da0aa173e5e912b9059757274526d5c25
Diffstat (limited to 'client')
-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 |