diff --git a/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveSingleUrlTest.java b/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveSingleUrlTest.java index 423ecddce3..63bd1e53be 100644 --- a/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveSingleUrlTest.java +++ b/activemq-core/src/test/java/org/apache/activemq/broker/ft/QueueMasterSlaveSingleUrlTest.java @@ -30,6 +30,12 @@ public class QueueMasterSlaveSingleUrlTest extends QueueMasterSlaveTest { private final String brokerUrl = "tcp://localhost:62001"; private final String singleUriString = "failover://(" + brokerUrl +")?randomize=false"; + @Override + protected void setUp() throws Exception { + setAutoFail(true); + super.setUp(); + } + protected ActiveMQConnectionFactory createConnectionFactory() throws Exception { return new ActiveMQConnectionFactory(singleUriString); }