1 21 package com.presumo.jms.client; 22 23 import javax.jms.QueueSession ; 24 import javax.jms.JMSException ; 25 import javax.jms.InvalidDestinationException ; 26 import javax.jms.Queue ; 27 import javax.jms.QueueBrowser ; 28 import javax.jms.QueueReceiver ; 29 import javax.jms.QueueSender ; 30 import javax.jms.TemporaryQueue ; 31 32 import com.presumo.jms.resources.Resources; 33 import com.presumo.jms.router.Router; 34 import com.presumo.util.log.Logger; 35 import com.presumo.util.log.LoggerFactory; 36 37 40 public final class JmsQueueSession extends JmsSession 41 implements QueueSession 42 { 43 44 48 public JmsQueueSession(Router router, 49 boolean transacted, 50 int acknowledgeMode, 51 JmsConnection connx) 52 throws JMSException 53 { 54 super(router, transacted, acknowledgeMode, connx); 55 56 logger.entry("JmsQueueSession"); 57 logger.exit("JmsQueueSession"); 58 } 59 60 61 62 66 67 public Queue createQueue(String queueName) throws JMSException 68 { 69 logger.entry("createQueue"); 70 71 JmsQueue retval = new JmsQueue(queueName); 72 73 logger.exit("createTopic"); 74 return retval; 75 } 76 77 78 public QueueReceiver createReceiver(Queue queue) 79 throws JMSException 80 { 81 logger.entry("createReceiver", queue); 82 83 QueueReceiver r = createReceiver(queue, null); 84 85 logger.exit("createReceiver", r); 86 return r; 87 } 88 89 90 public QueueReceiver createReceiver(Queue queue, 91 String messageSelector) 92 throws JMSException 93 { 94 logger.entry("createReceiver", queue, messageSelector); 95 96 JmsQueueReceiver r = null; 97 98 if (! (queue instanceof JmsQueue)) throw new 99 InvalidDestinationException ("Queue must be from this implementation"); 100 if (closed) throw new 101 IllegalStateException ("Operation attempted on a closed object"); 102 103 r = new JmsQueueReceiver(this, messageSelector, (JmsQueue) queue, false); 104 105 logger.exit("createReceiver", r); 106 return r; 107 } 108 109 public QueueBrowser createBrowser(Queue queue) 110 throws JMSException 111 { 112 logger.entry("createBrowser", queue); 113 114 QueueBrowser b = createBrowser(queue, null); 115 116 logger.exit("createQueueBrowser", b); 117 return b; 118 } 119 120 121 public QueueBrowser createBrowser(Queue queue, 122 String messageSelector) 123 throws JMSException 124 { 125 logger.entry("createBrowser", queue, messageSelector); 126 127 if (! (queue instanceof JmsQueue)) throw new 128 InvalidDestinationException ("Queue must be from this implementation"); 129 if (closed) throw new 130 IllegalStateException ("Operation attempted on a closed object"); 131 132 JmsQueueReceiver r = null; 133 r = new JmsQueueReceiver(this, messageSelector, (JmsQueue) queue, false); 134 QueueBrowser b = new JmsQueueBrowser(r); 135 136 logger.exit("createBrowser", b); 137 return b; 138 } 139 140 141 public QueueSender createSender(Queue queue) 142 throws JMSException 143 { 144 logger.entry("createSender", queue); 145 146 if (! (queue instanceof JmsQueue)) throw new 147 InvalidDestinationException ("Queue must be from this implementation"); 148 if (closed) throw new 149 IllegalStateException ("Operation attempted on a closed object"); 150 151 QueueSender qs = new JmsQueueSender(this, (JmsQueue) queue); 152 153 logger.exit("createSender", qs); 154 return qs; 155 } 156 157 158 161 public TemporaryQueue createTemporaryQueue() throws JMSException 162 { 163 throw new JMSException ("Operation not implemented"); 164 } 165 166 168 private static Logger logger = 169 LoggerFactory.getLogger(JmsTopicSession.class, Resources.getBundle()); 170 171 173 } 174 175 176 | Popular Tags |