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