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