1 28 29 package com.caucho.jms.session; 30 31 import javax.jms.JMSException ; 32 import javax.jms.Message ; 33 import javax.jms.Queue ; 34 import javax.jms.QueueSender ; 35 36 39 public class QueueSenderImpl extends MessageProducerImpl 40 implements QueueSender { 41 public QueueSenderImpl(SessionImpl session, Queue queue) 42 { 43 super(session, queue); 44 } 45 46 49 public Queue getQueue() 50 { 51 return (Queue ) getDestination(); 52 } 53 54 60 public void send(Queue queue, Message message) 61 throws JMSException 62 { 63 super.send(queue, message); 64 } 65 66 75 public void send(Queue queue, 76 Message message, 77 int deliveryMode, 78 int priority, 79 long timeToLive) 80 throws JMSException 81 { 82 super.send(queue, message, deliveryMode, priority, timeToLive); 83 } 84 } 85 86 | Popular Tags |