1 18 package org.apache.activemq.broker.virtual; 19 20 import org.apache.activemq.command.ActiveMQQueue; 21 import org.apache.activemq.command.ActiveMQTopic; 22 23 import javax.jms.Destination ; 24 25 29 public class CompositeTopicTest extends CompositeQueueTest { 30 31 protected Destination getConsumer1Dsetination() { 32 return new ActiveMQQueue("FOO"); 33 } 34 35 protected Destination getConsumer2Dsetination() { 36 return new ActiveMQTopic("BAR"); 37 } 38 39 protected Destination getProducerDestination() { 40 return new ActiveMQTopic("MY.TOPIC"); 41 } 42 43 protected String getBrokerConfigUri() { 44 return "org/apache/activemq/broker/virtual/composite-topic.xml"; 45 } 46 } 47 | Popular Tags |