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.RecoveryBrokerTest; 27 28 33 public class DefaultStoreRecoveryBrokerTest extends RecoveryBrokerTest { 34 35 protected BrokerService createBroker() throws Exception { 36 return BrokerFactory.createBroker(new URI ("broker://()/localhost?deleteAllMessagesOnStartup=true")); 37 } 38 39 protected BrokerService createRestartedBroker() throws Exception { 40 return BrokerFactory.createBroker(new URI ("broker://()/localhost")); 41 } 42 43 public static Test suite() { 44 return suite(DefaultStoreRecoveryBrokerTest.class); 45 } 46 47 public static void main(String [] args) { 48 junit.textui.TestRunner.run(suite()); 49 } 50 51 } 52 | Popular Tags |