Repository: wicket Updated Branches: refs/heads/wicket-7.x 020706d5b -> b9e22fb42
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/b9e22fb4 Tree: http://git-wip-us.apache.org/repos/asf/wicket/tree/b9e22fb4 Diff: http://git-wip-us.apache.org/repos/asf/wicket/diff/b9e22fb4 Branch: refs/heads/wicket-7.x Commit: b9e22fb42c6aad635990296705af232d23a8f2ca Parents: 020706d 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:17:47 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/b9e22fb4/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();
