1 18 package org.apache.activemq.broker.store; 19 20 import java.net.URI ; 21 22 import junit.framework.Test; 23 24 import org.apache.activemq.broker.BrokerFactory; 25 import org.apache.activemq.broker.BrokerService; 26 import org.apache.activemq.broker.XARecoveryBrokerTest; 27 28 33 public class DefaultStoreXARecoveryBrokerTest extends XARecoveryBrokerTest { 34 35 public static Test suite() { 36 return suite(DefaultStoreXARecoveryBrokerTest.class); 37 } 38 39 public static void main(String [] args) { 40 junit.textui.TestRunner.run(suite()); 41 } 42 43 protected BrokerService createBroker() throws Exception { 44 return BrokerFactory.createBroker(new URI ("broker://()/localhost?deleteAllMessagesOnStartup=true")); 45 } 46 47 protected BrokerService createRestartedBroker() throws Exception { 48 return BrokerFactory.createBroker(new URI ("broker://()/localhost")); 49 } 50 51 } 52 | Popular Tags |