You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wicket.apache.org by mg...@apache.org on 2016/03/08 23:37:06 UTC

[25/52] [abbrv] wicket git commit: WICKET-6103 Synchronization on JSR 356 connection

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 <mg...@apache.org>
Authored: Fri Feb 26 11:17:47 2016 +0100
Committer: Martin Tzvetanov Grigorov <mg...@apache.org>
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();