Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

prevent hanging test stalling the build. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1324779 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy A. Bish 2012-04-11 14:23:27 +00:00
parent 76537741fc
commit 0c2144c357
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
activemq-core/src/test/java/org/apache/activemq/usecases/ClientRebalanceTest.java
View File

@ -16,11 +16,6 @@
*/ */
package org.apache.activemq.usecases; package org.apache.activemq.usecases;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.JmsMultipleBrokersTestSupport;
import org.apache.log4j.Logger;
import org.springframework.core.io.ClassPathResource;
import javax.jms.Connection; import javax.jms.Connection;
import javax.jms.Message; import javax.jms.Message;
import javax.jms.MessageConsumer; import javax.jms.MessageConsumer;
@ -28,10 +23,20 @@ import javax.jms.MessageProducer;
import javax.jms.Queue; import javax.jms.Queue;
import javax.jms.Session; import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.JmsMultipleBrokersTestSupport;
import org.apache.log4j.Logger;
import org.springframework.core.io.ClassPathResource;
public class ClientRebalanceTest extends JmsMultipleBrokersTestSupport { public class ClientRebalanceTest extends JmsMultipleBrokersTestSupport {
private static final Logger LOG = Logger.getLogger(ClientRebalanceTest.class); private static final Logger LOG = Logger.getLogger(ClientRebalanceTest.class);
private static final String QUEUE_NAME = "Test.ClientRebalanceTest"; private static final String QUEUE_NAME = "Test.ClientRebalanceTest";
protected void setUp() throws Exception {
setAutoFail(true);
super.setUp();
}
public void testRebalance() throws Exception { public void testRebalance() throws Exception {
createBroker(new ClassPathResource("org/apache/activemq/usecases/rebalance-broker1.xml")); createBroker(new ClassPathResource("org/apache/activemq/usecases/rebalance-broker1.xml"));
createBroker(new ClassPathResource("org/apache/activemq/usecases/rebalance-broker2.xml")); createBroker(new ClassPathResource("org/apache/activemq/usecases/rebalance-broker2.xml"));
@ -40,9 +45,8 @@ public class ClientRebalanceTest extends JmsMultipleBrokersTestSupport {
brokers.get("b1").broker.waitUntilStarted(); brokers.get("b1").broker.waitUntilStarted();
LOG.info("Starting connection"); LOG.info("Starting connection");
ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("failover:(tcp://localhost:61616,tcp://localhost:61617)?randomize=false"); ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("failover:(tcp://localhost:61616,tcp://localhost:61617)?randomize=false");
Connection conn = factory.createConnection(); Connection conn = factory.createConnection();
conn.start(); conn.start();
@ -55,20 +59,17 @@ public class ClientRebalanceTest extends JmsMultipleBrokersTestSupport {
Message msg = consumer.receive(2000); Message msg = consumer.receive(2000);
assertNotNull(msg); assertNotNull(msg);
// introduce third broker // introduce third broker
createBroker(new ClassPathResource("org/apache/activemq/usecases/rebalance-broker3.xml")); createBroker(new ClassPathResource("org/apache/activemq/usecases/rebalance-broker3.xml"));
brokers.get("b3").broker.waitUntilStarted(); brokers.get("b3").broker.waitUntilStarted();
Thread.sleep(1000);
Thread.sleep(1000);
LOG.info("Stopping broker 1"); LOG.info("Stopping broker 1");
brokers.get("b1").broker.stop(); brokers.get("b1").broker.stop();
brokers.get("b1").broker.waitUntilStopped(); brokers.get("b1").broker.waitUntilStopped();
Thread.sleep(1000); Thread.sleep(1000);
// should reconnect to some of the remaining brokers // should reconnect to some of the remaining brokers
producer.send(message); producer.send(message);
@ -85,5 +86,4 @@ public class ClientRebalanceTest extends JmsMultipleBrokersTestSupport {
msg = consumer.receive(2000); msg = consumer.receive(2000);
assertNotNull(msg); assertNotNull(msg);
} }
} }