|
1
46
47 package org.mr.api.jms;
48
49
56
57 import javax.jms.JMSException  ;
58 import javax.jms.QueueSession ;
59 import javax.jms.TopicSession ;
60 import javax.jms.XAConnection ;
61 import javax.jms.XAQueueConnection ;
62 import javax.jms.XAQueueSession ;
63 import javax.jms.XASession ;
64 import javax.jms.XATopicConnection ;
65 import javax.jms.XATopicSession ;
66
67 public class MantaXAConnection extends MantaConnection implements XAConnection , XATopicConnection , XAQueueConnection {
68
69 MantaXAConnection(MantaConnectionFactory factory, String userName, String password) throws JMSException {
70 super(factory, userName, password);
71
72 }
73
74 public XASession createXASession() throws JMSException {
75 checkLegalOperation();
76 MantaXASession mxs = new MantaXASession(this);
77 addSession(mxs);
78 return mxs;
79 }
80
81
82 public XATopicSession createXATopicSession() throws JMSException {
83 return (XATopicSession )createXASession();
84 }
85
86
87 public TopicSession createTopicSession(boolean trx, int ackMode) throws JMSException {
88 checkLegalOperation();
89 MantaTopicSession cts = new MantaTopicSession(this.getChannel().getMessageId(),
90 this,trx,ackMode);
91
92 addSession(cts);
93 return cts;
94 }
95
96
97 public XAQueueSession createXAQueueSession() throws JMSException {
98 return (XAQueueSession )createXASession();
99 }
100
101
102 public QueueSession createQueueSession(boolean trx, int ackMode) throws JMSException {
103 checkLegalOperation();
104 MantaQueueSession mqs = new MantaQueueSession(this.getChannel().getMessageId(),
105 this,trx,ackMode);
106
107 addSession(mqs);
108 return mqs;
109 }
110
111 }
112 |
Popular Tags |
Java API By Example, From Geeks To Geeks.