1 18 19 package org.apache.activemq; 20 21 import javax.jms.JMSException ; 22 import javax.jms.Message ; 23 import javax.jms.Queue ; 24 import javax.jms.QueueSender ; 25 26 import org.apache.activemq.command.ActiveMQDestination; 27 28 74 75 public class ActiveMQQueueSender extends ActiveMQMessageProducer implements QueueSender { 76 77 protected ActiveMQQueueSender(ActiveMQSession session, ActiveMQDestination destination) 78 throws JMSException { 79 super(session, 80 session.getNextProducerId(), 81 destination); 82 } 83 84 91 92 public Queue getQueue() throws JMSException { 93 return (Queue ) super.getDestination(); 94 } 95 96 114 115 public void send(Queue queue, Message message) throws JMSException { 116 super.send(queue, message); 117 } 118 119 136 137 public void send(Queue queue, Message message, int deliveryMode, int priority, long timeToLive) 138 throws JMSException { 139 super.send(queue, 140 message, 141 deliveryMode, 142 priority, 143 timeToLive); 144 } 145 } 146 | Popular Tags |