1 21 package com.presumo.jms.client; 22 23 import javax.jms.IllegalStateException ; 24 import javax.jms.JMSException ; 25 import javax.jms.Message ; 26 import javax.jms.Queue ; 27 import javax.jms.QueueSender ; 28 29 32 public final class JmsQueueSender extends JmsMessageProducer 33 implements QueueSender 34 { 35 36 private final JmsQueue queue; 37 38 42 JmsQueueSender(JmsQueueSession session, JmsQueue queue) 43 { 44 super(session); 45 this.queue = queue; 46 } 47 48 49 53 public Queue getQueue() throws JMSException 54 { 55 return queue; 56 } 57 58 59 public final void send(Message message) throws JMSException 60 { 61 prepareAndSend(this.queue, message, this.deliveryMode, 62 this.priority, this.timeToLive); 63 } 64 65 66 public final void send(Message message, 67 int deliveryMode, 68 int priority, 69 long timeToLive) 70 throws JMSException 71 { 72 prepareAndSend(this.queue, message, deliveryMode, priority, timeToLive); 73 } 74 75 76 public final void send(Queue queue, Message message) throws JMSException 77 { 78 prepareAndSend(queue, message, this.deliveryMode, 79 this.priority, this.timeToLive); 80 } 81 82 83 public final void send(Queue queue, 84 Message message, 85 int deliveryMode, 86 int priority, 87 long timeToLive) 88 throws JMSException 89 { 90 prepareAndSend(queue, message, deliveryMode, priority, timeToLive); 91 } 92 93 94 } 95 | Popular Tags |