You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ro...@apache.org on 2017/09/01 12:01:23 UTC
activemq git commit: AMQ-6801: ensure transport listener is set
before tripping latch to indicate startup is occuring
Repository: activemq
Updated Branches:
refs/heads/master 5e656d394 -> 2e492569d
AMQ-6801: ensure transport listener is set before tripping latch to indicate startup is occuring
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/2e492569
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/2e492569
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/2e492569
Branch: refs/heads/master
Commit: 2e492569db2345cf3be8532630f93219159a8b15
Parents: 5e656d3
Author: Robbie Gemmell <ro...@apache.org>
Authored: Fri Sep 1 13:00:35 2017 +0100
Committer: Robbie Gemmell <ro...@apache.org>
Committed: Fri Sep 1 13:00:35 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/activemq/transport/ws/WSTransportProxy.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/2e492569/activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportProxy.java
----------------------------------------------------------------------
diff --git a/activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportProxy.java b/activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportProxy.java
index d5a5207..e1a2f90 100644
--- a/activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportProxy.java
+++ b/activemq-http/src/main/java/org/apache/activemq/transport/ws/WSTransportProxy.java
@@ -149,9 +149,9 @@ public final class WSTransportProxy extends TransportSupport implements Transpor
@Override
protected void doStart() throws Exception {
+ transport.setTransportListener(getTransportListener());
socketTransportStarted.countDown();
- transport.setTransportListener(getTransportListener());
transport.start();
}