1 18 package org.apache.activemq; 19 20 import org.apache.activemq.command.ActiveMQDestination; 21 import org.apache.activemq.command.ConsumerId; 22 23 import javax.jms.JMSException ; 24 import javax.jms.Queue ; 25 import javax.jms.QueueReceiver ; 26 27 57 58 public class ActiveMQQueueReceiver extends ActiveMQMessageConsumer implements 59 QueueReceiver { 60 61 70 protected ActiveMQQueueReceiver(ActiveMQSession theSession, 71 ConsumerId consumerId, ActiveMQDestination destination, String selector, int prefetch, int maximumPendingMessageCount, boolean asyncDispatch) 72 throws JMSException { 73 super(theSession, consumerId, destination, null, selector, prefetch, maximumPendingMessageCount, false, false, asyncDispatch); 74 } 75 76 83 84 public Queue getQueue() throws JMSException { 85 checkClosed(); 86 return (Queue ) super.getDestination(); 87 } 88 89 } 90 | Popular Tags |