|
1
46
47 package org.mr.api.jms;
48
49 import java.io.Serializable  ;
50
51 import javax.jms.JMSException ;
52 import javax.jms.QueueConnection ;
53 import javax.jms.TopicConnection ;
54 import javax.jms.XAConnection ;
55 import javax.jms.XAConnectionFactory ;
56 import javax.jms.XAQueueConnection ;
57 import javax.jms.XAQueueConnectionFactory ;
58 import javax.jms.XATopicConnection ;
59 import javax.jms.XATopicConnectionFactory ;
60 import javax.naming.NamingException ;
61 import javax.naming.Reference ;
62 import javax.naming.Referenceable ;
63 import javax.naming.StringRefAddr ;
64
65
70
71 public class MantaXAConnectionFactory extends MantaConnectionFactory implements XAConnectionFactory ,
72 XATopicConnectionFactory , XAQueueConnectionFactory , Serializable , Referenceable {
73
74
80 public MantaXAConnectionFactory() {
81 super();
82
83 }
84 public MantaXAConnectionFactory(String s) {
85 super(s);
86
87 }
88
89 public XAConnection createXAConnection() throws JMSException {
90
91 return new MantaXAConnection(this,"","");
92 }
93
94
95 public XAConnection createXAConnection(String name, String pwd) throws JMSException {
96
97 return new MantaXAConnection(this,name,pwd);
98 }
99
100
101
105 public Reference getReference() throws NamingException {
106 return new Reference (
107 getClass().getName(),
108 new StringRefAddr ("name",this.name),
109 MantaConnectionFactoryFactory.class.getName(),
110 null
111 );
112 }
113
114 public XATopicConnection createXATopicConnection() throws JMSException {
115
116 return new MantaXAConnection(this,"","");
117 }
118
119
120 public XATopicConnection createXATopicConnection(String name, String pwd) throws JMSException {
121
122 return new MantaXAConnection(this,name,pwd);
123 }
124
125 public TopicConnection createTopicConnection() throws JMSException {
126
127 return new MantaTopicConnection(this,"","");
128 }
129
130 public TopicConnection createTopicConnection(String name, String pwd) throws JMSException {
131 return new MantaTopicConnection(this,name,pwd);
132 }
133
134
135 public XAQueueConnection createXAQueueConnection() throws JMSException {
136 return new MantaXAConnection(this,"","");
137 }
138
139
140 public XAQueueConnection createXAQueueConnection(String name, String pwd) throws JMSException {
141 return new MantaXAConnection(this,name,pwd);
142 }
143
144
145 public QueueConnection createQueueConnection() throws JMSException {
146 return new MantaQueueConnection(this,"","");
147 }
148
149
150 public QueueConnection createQueueConnection(String name, String pwd) throws JMSException {
151 return new MantaQueueConnection(this,name,pwd);
152 }
153
154 }
155 |
Popular Tags |
Java API By Example, From Geeks To Geeks.