1 18 package org.apache.activemq.command; 19 20 import javax.jms.JMSException ; 21 import javax.jms.TemporaryTopic ; 22 23 27 public class ActiveMQTempTopic extends ActiveMQTempDestination implements TemporaryTopic { 28 29 private static final long serialVersionUID = -4325596784597300253L; 30 public static final byte DATA_STRUCTURE_TYPE=CommandTypes.ACTIVEMQ_TEMP_TOPIC; 31 32 public ActiveMQTempTopic() { 33 } 34 35 public ActiveMQTempTopic(String name) { 36 super(name); 37 } 38 39 public ActiveMQTempTopic(ConnectionId connectionId, long sequenceId) { 40 super(connectionId.getValue(), sequenceId); 41 } 42 43 44 public byte getDataStructureType() { 45 return DATA_STRUCTURE_TYPE; 46 } 47 48 public boolean isTopic() { 49 return true; 50 } 51 52 public String getTopicName() throws JMSException { 53 return getPhysicalName(); 54 } 55 56 public byte getDestinationType() { 57 return TEMP_TOPIC_TYPE; 58 } 59 60 protected String getQualifiedPrefix() { 61 return TEMP_TOPIC_QUALIFED_PREFIX; 62 } 63 } 64 | Popular Tags |