WICKET-6107 Broadcast onClose event regardless of the JSR 356 WebSocket connection closed state
Project: http://git-wip-us.apache.org/repos/asf/wicket/repo Commit: http://git-wip-us.apache.org/repos/asf/wicket/commit/ffa34c6b Tree: http://git-wip-us.apache.org/repos/asf/wicket/tree/ffa34c6b Diff: http://git-wip-us.apache.org/repos/asf/wicket/diff/ffa34c6b Branch: refs/heads/lambdas Commit: ffa34c6bfbd2ccd8340e23ff1601edd3e0e941d6 Parents: 7f503f9 Author: Martin Tzvetanov Grigorov <[email protected]> Authored: Fri Feb 26 22:02:18 2016 +0100 Committer: Martin Tzvetanov Grigorov <[email protected]> Committed: Fri Feb 26 22:03:09 2016 +0100 ---------------------------------------------------------------------- .../apache/wicket/protocol/ws/api/AbstractWebSocketProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/wicket/blob/ffa34c6b/wicket-native-websocket/wicket-native-websocket-core/src/main/java/org/apache/wicket/protocol/ws/api/AbstractWebSocketProcessor.java ---------------------------------------------------------------------- diff --git a/wicket-native-websocket/wicket-native-websocket-core/src/main/java/org/apache/wicket/protocol/ws/api/AbstractWebSocketProcessor.java b/wicket-native-websocket/wicket-native-websocket-core/src/main/java/org/apache/wicket/protocol/ws/api/AbstractWebSocketProcessor.java index 7768acd..2129fa2 100644 --- a/wicket-native-websocket/wicket-native-websocket-core/src/main/java/org/apache/wicket/protocol/ws/api/AbstractWebSocketProcessor.java +++ b/wicket-native-websocket/wicket-native-websocket-core/src/main/java/org/apache/wicket/protocol/ws/api/AbstractWebSocketProcessor.java @@ -207,7 +207,7 @@ public abstract class AbstractWebSocketProcessor implements IWebSocketProcessor IKey key = getRegistryKey(); IWebSocketConnection connection = connectionRegistry.getConnection(application, sessionId, key); - if (connection != null && connection.isOpen()) + if (connection != null && (connection.isOpen() || message instanceof ClosedMessage)) { Application oldApplication = ThreadContext.getApplication(); Session oldSession = ThreadContext.getSession();
