diff --git a/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java b/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java index eb0ee9ab02..2bc281f0b8 100755 --- a/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java +++ b/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java @@ -16,6 +16,7 @@ */ package org.apache.activemq.usecases; +import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.test.TestSupport; import javax.jms.Connection; @@ -40,6 +41,10 @@ public class DurableConsumerCloseAndReconnectTest extends TestSupport { private MessageProducer producer; private Destination destination; + protected ActiveMQConnectionFactory createConnectionFactory() throws Exception { + return new ActiveMQConnectionFactory("vm://localhost?broker.persistent=true"); + } + public void testCreateDurableConsumerCloseThenReconnect() throws Exception { // force the server to stay up across both connection tests Connection dummyConnection = createConnection();