|                                                                                                              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                                                                                                                                                                                              |