You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by cs...@apache.org on 2016/11/04 16:56:28 UTC

[2/2] activemq git commit: proposed websocket fix

proposed websocket fix


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/946c9454
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/946c9454
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/946c9454

Branch: refs/heads/master
Commit: 946c9454d512280cdae525ba25db370f2b61ff43
Parents: 7cf7fba
Author: Christopher L. Shannon (cshannon) <ch...@gmail.com>
Authored: Thu Nov 3 08:41:37 2016 -0400
Committer: Christopher L. Shannon (cshannon) <ch...@gmail.com>
Committed: Fri Nov 4 12:56:20 2016 -0400

----------------------------------------------------------------------
 .../java/org/apache/activemq/transport/ws/jetty9/StompSocket.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/946c9454/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/StompSocket.java
----------------------------------------------------------------------
diff --git a/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/StompSocket.java b/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/StompSocket.java
index ee012db..76ac560 100644
--- a/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/StompSocket.java
+++ b/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/StompSocket.java
@@ -44,7 +44,8 @@ public class StompSocket extends AbstractStompSocket implements WebSocketListene
 
     @Override
     public void sendToStomp(StompFrame command) throws IOException {
-        session.getRemote().sendString(command.format());
+        //Send async - do we need to wait for the future to complete?
+        session.getRemote().sendStringByFuture(command.format());
     }
 
     @Override