You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2014/06/05 23:52:07 UTC
git commit: Convert to JUnit 4 test and add a timeout,
also remove the tcp transport connector on a fixed port as its not
needed.
Repository: activemq
Updated Branches:
refs/heads/trunk 707940f1a -> b8830ddab
Convert to JUnit 4 test and add a timeout, also remove the tcp transport
connector on a fixed port as its not needed.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/b8830dda
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/b8830dda
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/b8830dda
Branch: refs/heads/trunk
Commit: b8830ddab15bd5739f8ec30de81d9e98908727aa
Parents: 707940f
Author: Timothy Bish <ta...@gmail.com>
Authored: Thu Jun 5 17:52:01 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Thu Jun 5 17:52:01 2014 -0400
----------------------------------------------------------------------
.../transport/vm/VMTransportWaitForTest.java | 48 +++++++++++---------
1 file changed, 26 insertions(+), 22 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/b8830dda/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportWaitForTest.java
----------------------------------------------------------------------
diff --git a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportWaitForTest.java b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportWaitForTest.java
index 505e65c..faa93e4 100644
--- a/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportWaitForTest.java
+++ b/activemq-unit-tests/src/test/java/org/apache/activemq/transport/vm/VMTransportWaitForTest.java
@@ -16,28 +16,32 @@
*/
package org.apache.activemq.transport.vm;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
import java.net.URI;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import javax.jms.JMSException;
-import junit.framework.TestCase;
-
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
+import org.junit.Test;
-public class VMTransportWaitForTest extends TestCase {
+public class VMTransportWaitForTest {
- private static final String VM_BROKER_URI_NO_WAIT =
+ private static final String VM_BROKER_URI_NO_WAIT =
"vm://localhost?broker.persistent=false&create=false";
-
- private static final String VM_BROKER_URI_WAIT_FOR_START =
+
+ private static final String VM_BROKER_URI_WAIT_FOR_START =
VM_BROKER_URI_NO_WAIT + "&waitForStart=20000";
-
+
CountDownLatch started = new CountDownLatch(1);
CountDownLatch gotConnection = new CountDownLatch(1);
+ @Test(timeout=90000)
public void testWaitFor() throws Exception {
try {
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(new URI(VM_BROKER_URI_NO_WAIT));
@@ -45,32 +49,32 @@ public class VMTransportWaitForTest extends TestCase {
fail("expect broker not exist exception");
} catch (JMSException expectedOnNoBrokerAndNoCreate) {
}
-
- // spawn a thread that will wait for an embedded broker to start via vm://..
+
+ // spawn a thread that will wait for an embedded broker to start via
+ // vm://..
Thread t = new Thread() {
+ @Override
public void run() {
- try {
- started.countDown();
- ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(new URI(VM_BROKER_URI_WAIT_FOR_START));
- cf.createConnection();
- gotConnection.countDown();
-
- } catch (Exception e) {
- e.printStackTrace();
- fail("unexpected exception: " + e);
- }
+ try {
+ started.countDown();
+ ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(new URI(VM_BROKER_URI_WAIT_FOR_START));
+ cf.createConnection();
+ gotConnection.countDown();
+ } catch (Exception e) {
+ e.printStackTrace();
+ fail("unexpected exception: " + e);
+ }
}
};
t.start();
started.await(20, TimeUnit.SECONDS);
Thread.yield();
assertFalse("has not got connection", gotConnection.await(2, TimeUnit.SECONDS));
-
+
BrokerService broker = new BrokerService();
broker.setPersistent(false);
- broker.addConnector("tcp://localhost:61616");
broker.start();
assertTrue("has got connection", gotConnection.await(400, TimeUnit.MILLISECONDS));
- broker.stop();
+ broker.stop();
}
}