1 18 package org.apache.activemq.broker.virtual; 19 20 import org.apache.activemq.broker.BrokerService; 21 import org.apache.activemq.xbean.XBeanBrokerFactory; 22 23 import java.net.URI ; 24 25 29 public class VirtualTopicPubSubUsingXBeanTest extends VirtualTopicPubSubTest { 30 31 protected String getVirtualTopicConsumerName() { 32 return "VirtualTopicConsumers.ConsumerNumberOne.FOO"; 33 } 34 35 protected String getVirtualTopicName() { 36 return "FOO"; 37 } 38 39 protected BrokerService createBroker() throws Exception { 40 XBeanBrokerFactory factory = new XBeanBrokerFactory(); 41 BrokerService answer = factory.createBroker(new URI (getBrokerConfigUri())); 42 43 answer.setPersistent(false); 45 46 return answer; 47 } 48 49 protected String getBrokerConfigUri() { 50 return "org/apache/activemq/broker/virtual/global-virtual-topics.xml"; 51 } 52 53 } 54 | Popular Tags |