activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hadr...@apache.org
Subject [06/10] git commit: Adds a little test case for Http based discovery
Date Tue, 11 Mar 2014 23:29:32 GMT
Adds a little test case for Http based discovery


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

Branch: refs/heads/activemq-5.9
Commit: 3c8651ec930dd12c20ec08c08e5621574f3ab0a3
Parents: bce750f
Author: Timothy Bish <tabish121@gmai.com>
Authored: Fri Oct 18 17:27:13 2013 -0400
Committer: Hadrian Zbarcea <hadrian@apache.org>
Committed: Tue Mar 11 17:05:39 2014 -0400

----------------------------------------------------------------------
 .../discovery/http/HttpDiscoveryTest.java       | 70 ++++++++++++++++++++
 1 file changed, 70 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/3c8651ec/activemq-http/src/test/java/org/apache/activemq/transport/discovery/http/HttpDiscoveryTest.java
----------------------------------------------------------------------
diff --git a/activemq-http/src/test/java/org/apache/activemq/transport/discovery/http/HttpDiscoveryTest.java
b/activemq-http/src/test/java/org/apache/activemq/transport/discovery/http/HttpDiscoveryTest.java
new file mode 100644
index 0000000..72104af
--- /dev/null
+++ b/activemq-http/src/test/java/org/apache/activemq/transport/discovery/http/HttpDiscoveryTest.java
@@ -0,0 +1,70 @@
+package org.apache.activemq.transport.discovery.http;
+
+import static org.junit.Assert.assertTrue;
+
+import java.io.IOException;
+import java.net.URI;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+
+import org.apache.activemq.ActiveMQConnection;
+import org.apache.activemq.ActiveMQConnectionFactory;
+import org.apache.activemq.broker.BrokerService;
+import org.apache.activemq.broker.TransportConnector;
+import org.apache.activemq.transport.TransportListener;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+public class HttpDiscoveryTest implements TransportListener {
+
+    private BrokerService broker;
+    private ActiveMQConnectionFactory factory;
+    private final CountDownLatch discovered = new CountDownLatch(1);
+
+    @Before
+    public void setUp() throws Exception {
+
+        broker = new BrokerService();
+        TransportConnector connector = broker.addConnector("tcp://localhost:0");
+        connector.setDiscoveryUri(new URI("http://localhost:8181/default?startEmbeddRegistry=true"));
+        broker.setPersistent(false);
+        broker.setUseJmx(false);
+        broker.deleteAllMessages();
+        broker.start();
+
+        String connectionUri = "discovery:http://localhost:8181/default";
+        factory = new ActiveMQConnectionFactory(connectionUri + "?trace=true&soTimeout=1000");
+    }
+
+    @After
+    public void tearDown() throws Exception {
+        broker.stop();
+    }
+
+    @Test
+    public void testBrokerIsDiscovered() throws Exception {
+        factory.setTransportListener(this);
+        ActiveMQConnection connection = (ActiveMQConnection) factory.createConnection();
+        assertTrue(discovered.await(60, TimeUnit.SECONDS));
+        connection.close();
+    }
+
+    @Override
+    public void onCommand(Object command) {
+    }
+
+    @Override
+    public void onException(IOException error) {
+    }
+
+    @Override
+    public void transportInterupted() {
+    }
+
+    @Override
+    public void transportResumed() {
+        discovered.countDown();
+    }
+
+}


Mime
View raw message