You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by gt...@apache.org on 2014/10/17 00:54:36 UTC

[4/6] git commit: ensure vm transport is started in this test so that stop does some work

ensure vm transport is started in this test so that stop does some work


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

Branch: refs/heads/trunk
Commit: 2050498c6788a925efa24630803328286468c079
Parents: 5f865f0
Author: gtully <ga...@gmail.com>
Authored: Thu Oct 9 23:14:19 2014 +0100
Committer: gtully <ga...@gmail.com>
Committed: Thu Oct 16 23:35:18 2014 +0100

----------------------------------------------------------------------
 .../org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/2050498c/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java
index fa3ef3c..8534f89 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportThreadSafeTest.java
@@ -298,6 +298,7 @@ public class VMTransportThreadSafeTest {
 
         final VMTestTransportListener remoteListener = new VMTestTransportListener(remoteReceived);
         remote.setTransportListener(remoteListener);
+        remote.start();
 
         final Response[] answer = new Response[1];
         ResponseCorrelator responseCorrelator = new ResponseCorrelator(local);