|
1 package com.ubermq.jms.client.impl;
2
3 import com.ubermq.jms.common.datagram.*;
4
5 final class QueueSession
6 extends Session
7 implements javax.jms.QueueSession 
8 {
9
10 QueueSession(Connection c,
11 IMessageDatagramFactory f,
12 int ackMode)
13 {
14 super(c,
15 f,
16 ackMode);
17 }
18
19 public javax.jms.QueueReceiver createReceiver(javax.jms.Queue q) throws javax.jms.JMSException
20 {
21 return createReceiver(q, null);
22 }
23
24 public javax.jms.QueueReceiver createReceiver(javax.jms.Queue q, String selector) throws javax.jms.JMSException
25 {
26 return new QueueReceiver(q, selector, this);
27 }
28
29 public javax.jms.QueueSender createSender(javax.jms.Queue q) throws javax.jms.JMSException
30 {
31 return new QueueSender(q, this);
32 }
33
34 }
35 |
Popular Tags |
Java API By Example, From Geeks To Geeks.