WICKET-6103 Synchronization on JSR 356 connection Synchronize the send** and close() methods
Project: http://git-wip-us.apache.org/repos/asf/wicket/repo Commit: http://git-wip-us.apache.org/repos/asf/wicket/commit/ae36388c Tree: http://git-wip-us.apache.org/repos/asf/wicket/tree/ae36388c Diff: http://git-wip-us.apache.org/repos/asf/wicket/diff/ae36388c Branch: refs/heads/lambdas Commit: ae36388c00654b7260dde9782f4f1153447901e3 Parents: 02d6858 Author: Martin Tzvetanov Grigorov <[email protected]> Authored: Fri Feb 26 11:17:47 2016 +0100 Committer: Martin Tzvetanov Grigorov <[email protected]> Committed: Fri Feb 26 11:18:52 2016 +0100 ---------------------------------------------------------------------- .../wicket/protocol/ws/javax/JavaxWebSocketConnection.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/wicket/blob/ae36388c/wicket-native-websocket/wicket-native-websocket-javax/src/main/java/org/apache/wicket/protocol/ws/javax/JavaxWebSocketConnection.java ---------------------------------------------------------------------- diff --git a/wicket-native-websocket/wicket-native-websocket-javax/src/main/java/org/apache/wicket/protocol/ws/javax/JavaxWebSocketConnection.java b/wicket-native-websocket/wicket-native-websocket-javax/src/main/java/org/apache/wicket/protocol/ws/javax/JavaxWebSocketConnection.java index dfd875e..41fa304 100644 --- a/wicket-native-websocket/wicket-native-websocket-javax/src/main/java/org/apache/wicket/protocol/ws/javax/JavaxWebSocketConnection.java +++ b/wicket-native-websocket/wicket-native-websocket-javax/src/main/java/org/apache/wicket/protocol/ws/javax/JavaxWebSocketConnection.java @@ -59,7 +59,7 @@ public class JavaxWebSocketConnection extends AbstractWebSocketConnection } @Override - public void close(int code, String reason) + public synchronized void close(int code, String reason) { if (isOpen()) { @@ -74,7 +74,7 @@ public class JavaxWebSocketConnection extends AbstractWebSocketConnection } @Override - public IWebSocketConnection sendMessage(String message) throws IOException + public synchronized IWebSocketConnection sendMessage(String message) throws IOException { checkClosed(); @@ -83,7 +83,7 @@ public class JavaxWebSocketConnection extends AbstractWebSocketConnection } @Override - public IWebSocketConnection sendMessage(byte[] message, int offset, int length) + public synchronized IWebSocketConnection sendMessage(byte[] message, int offset, int length) throws IOException { checkClosed();
