1 18 package org.apache.activemq.command; 19 20 import javax.jms.JMSException ; 21 import javax.jms.Topic ; 22 23 30 public class ActiveMQTopic extends ActiveMQDestination implements Topic { 31 32 private static final long serialVersionUID = 7300307405896488588L; 33 public static final byte DATA_STRUCTURE_TYPE=CommandTypes.ACTIVEMQ_TOPIC; 34 35 public ActiveMQTopic() { 36 } 37 38 public ActiveMQTopic(String name) { 39 super(name); 40 } 41 42 public byte getDataStructureType() { 43 return DATA_STRUCTURE_TYPE; 44 } 45 46 public boolean isTopic() { 47 return true; 48 } 49 50 public String getTopicName() throws JMSException { 51 return getPhysicalName(); 52 } 53 54 public byte getDestinationType() { 55 return TOPIC_TYPE; 56 } 57 58 protected String getQualifiedPrefix() { 59 return TOPIC_QUALIFIED_PREFIX; 60 } 61 62 } 63 | Popular Tags |