Author: chirino
Date: Fri Feb 10 13:14:08 2006
New Revision: 376860
URL: http://svn.apache.org/viewcvs?rev=376860&view=rev
Log:
Fixing DurableConsumerCloseAndReconnectTest, make sure a persistent broker is
used.
Modified:
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java
Modified:
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java?rev=376860&r1=376859&r2=376860&view=diff
==============================================================================
---
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java
(original)
+++
incubator/activemq/trunk/assembly/src/test/java/org/apache/activemq/usecases/DurableConsumerCloseAndReconnectTest.java
Fri Feb 10 13:14:08 2006
@@ -16,6 +16,7 @@
*/
package org.apache.activemq.usecases;
+import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.test.TestSupport;
import javax.jms.Connection;
@@ -39,6 +40,10 @@
private MessageConsumer consumer;
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
