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) <[email protected]> Authored: Thu Nov 3 08:41:37 2016 -0400 Committer: Christopher L. Shannon (cshannon) <[email protected]> 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
