1 25 package org.objectweb.joram.client.connector; 26 27 import org.objectweb.joram.client.jms.ha.local.XAHALocalConnectionFactory; 28 import org.objectweb.joram.client.jms.ha.local.XAQueueHALocalConnectionFactory; 29 import org.objectweb.joram.client.jms.ha.tcp.XAHATcpConnectionFactory; 30 import org.objectweb.joram.client.jms.ha.tcp.XAQueueHATcpConnectionFactory; 31 import org.objectweb.joram.client.jms.local.XALocalConnectionFactory; 32 import org.objectweb.joram.client.jms.local.XAQueueLocalConnectionFactory; 33 import org.objectweb.joram.client.jms.tcp.QueueTcpConnectionFactory; 34 import org.objectweb.joram.client.jms.tcp.TcpConnectionFactory; 35 import org.objectweb.joram.client.jms.tcp.XATcpConnectionFactory; 36 import org.objectweb.joram.client.jms.tcp.XAQueueTcpConnectionFactory; 37 38 import javax.jms.ConnectionFactory ; 39 import javax.jms.JMSException ; 40 import javax.jms.JMSSecurityException ; 41 import javax.jms.IllegalStateException ; 42 import javax.jms.QueueConnectionFactory ; 43 import javax.jms.XAConnection ; 44 import javax.jms.XAQueueConnection ; 45 import javax.jms.XAConnectionFactory ; 46 import javax.jms.XAQueueConnectionFactory ; 47 import javax.naming.StringRefAddr ; 48 import javax.naming.Reference ; 49 import javax.resource.ResourceException ; 50 import javax.resource.spi.CommException ; 51 import javax.resource.spi.ConnectionManager ; 52 import javax.resource.spi.ConnectionRequestInfo ; 53 import javax.resource.spi.ManagedConnection ; 54 import javax.resource.spi.ResourceAdapter ; 55 import javax.resource.spi.SecurityException ; 56 import javax.security.auth.Subject ; 57 58 import java.io.PrintWriter ; 59 import java.util.Iterator ; 60 import java.util.Set ; 61 import java.util.Vector ; 62 63 import org.objectweb.util.monolog.api.BasicLevel; 64 65 69 public class ManagedQueueConnectionFactoryImpl 70 extends ManagedConnectionFactoryImpl 71 implements javax.resource.spi.ManagedConnectionFactory , 72 javax.resource.spi.ResourceAdapterAssociation , 73 javax.resource.spi.ValidatingManagedConnectionFactory , 74 java.io.Serializable ![JavaDoc](../../../../../../cmn/javadoc.gif) 75 { 76 79 public ManagedQueueConnectionFactoryImpl() 80 {} 81 82 83 91 public Object createConnectionFactory(ConnectionManager cxManager) 92 throws ResourceException { 93 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 94 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, this + " createConnectionFactory(" + cxManager + ")"); 95 96 return new OutboundQueueConnectionFactory(this, cxManager); 97 } 98 99 105 public Object createConnectionFactory() 106 throws ResourceException { 107 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 108 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, this + " createConnectionFactory()"); 109 110 OutboundConnectionFactory factory = 111 new OutboundQueueConnectionFactory(this, 112 DefaultConnectionManager.getRef()); 113 114 Reference ref = 115 new Reference (factory.getClass().getName(), 116 "org.objectweb.joram.client.connector.ObjectFactoryImpl", 117 null); 118 ref.add(new StringRefAddr ("hostName", hostName)); 119 ref.add(new StringRefAddr ("serverPort", "" + serverPort)); 120 ref.add(new StringRefAddr ("userName", userName)); 121 ref.add(new StringRefAddr ("password", password)); 122 123 factory.setReference(ref); 124 return factory; 125 } 126 127 143 public ManagedConnection ![JavaDoc](../../../../../../cmn/javadoc.gif) 144 createManagedConnection(Subject subject, 145 ConnectionRequestInfo cxRequest) 146 throws ResourceException { 147 148 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 149 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, 150 this + " createManagedConnection(" + subject + 151 ", " + cxRequest + ")"); 152 153 String userName; 154 String password; 155 156 String hostName = this.hostName; 157 int serverPort = this.serverPort; 158 159 if (cxRequest == null) { 162 userName = this.userName; 163 password = this.password; 164 } 165 else { 166 if (! (cxRequest instanceof ConnectionRequest)) { 167 if (out != null) 168 out.print("Provided ConnectionRequestInfo instance is not a JORAM object."); 169 throw new ResourceException ("Provided ConnectionRequestInfo instance " 170 + "is not a JORAM object."); 171 } 172 173 userName = ((ConnectionRequest) cxRequest).getUserName(); 174 password = ((ConnectionRequest) cxRequest).getPassword(); 175 } 176 177 XAConnection cnx = null; 178 179 if (collocated) { 180 hostName = "localhost"; 181 serverPort = -1; 182 } 183 184 try { 185 186 if (isHa) { 187 if (collocated) { 188 if (cxRequest instanceof QueueConnectionRequest) { 189 XAQueueConnectionFactory factory = XAQueueHALocalConnectionFactory.create(); 190 setParameters(factory); 191 cnx = factory.createXAQueueConnection(userName, password); 192 } else { 193 XAConnectionFactory factory = XAHALocalConnectionFactory.create(); 194 setParameters(factory); 195 cnx = factory.createXAConnection(userName, password); 196 } 197 } else { 198 String urlHa = "hajoram://" + hostName + ":" + serverPort; 199 if (cxRequest instanceof QueueConnectionRequest) { 200 XAQueueConnectionFactory factory = XAQueueHATcpConnectionFactory.create(urlHa); 201 setParameters(factory); 202 cnx = factory.createXAQueueConnection(userName, password); 203 } else { 204 XAConnectionFactory factory = XAHATcpConnectionFactory.create(urlHa); 205 setParameters(factory); 206 cnx = factory.createXAConnection(userName, password); 207 } 208 } 209 } else { 210 if (collocated) { 211 if (cxRequest instanceof QueueConnectionRequest) { 212 XAQueueConnectionFactory factory = XAQueueLocalConnectionFactory.create(); 213 setParameters(factory); 214 cnx = factory.createXAQueueConnection(userName, password); 215 } else { 216 XAConnectionFactory factory = XALocalConnectionFactory.create(); 217 setParameters(factory); 218 cnx = factory.createXAConnection(userName, password); 219 } 220 } else { 221 if (cxRequest instanceof QueueConnectionRequest) { 222 XAQueueConnectionFactory factory = XAQueueTcpConnectionFactory.create(hostName, serverPort); 223 setParameters(factory); 224 cnx = factory.createXAQueueConnection(userName, password); 225 } else { 226 XAConnectionFactory factory = XATcpConnectionFactory.create(hostName, serverPort); 227 setParameters(factory); 228 cnx = factory.createXAConnection(userName, password); 229 } 230 } 231 } 232 233 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 234 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, this + " createManagedConnection cnx = " + cnx); 235 236 } catch (IllegalStateException exc) { 237 if (out != null) 238 out.print("Could not access the JORAM server: " + exc); 239 throw new CommException ("Could not access the JORAM server: " + exc); 240 } catch (JMSSecurityException exc) { 241 if (out != null) 242 out.print("Invalid user identification: " + exc); 243 throw new SecurityException ("Invalid user identification: " + exc); 244 } catch (JMSException exc) { 245 if (out != null) 246 out.print("Failed connecting process: " + exc); 247 throw new ResourceException ("Failed connecting process: " + exc); 248 } 249 250 ManagedConnection managedCx = new ManagedConnectionImpl(ra, 251 cnx, 252 hostName, 253 serverPort, 254 userName); 255 managedCx.setLogWriter(out); 256 257 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 258 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, 259 this + " createManagedConnection managedCx = " + managedCx); 260 261 return managedCx; 262 } 263 264 275 public ManagedConnection ![JavaDoc](../../../../../../cmn/javadoc.gif) 276 matchManagedConnections(Set connectionSet, 277 Subject subject, 278 ConnectionRequestInfo cxRequest) 279 throws ResourceException { 280 281 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 282 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, 283 this + " matchManagedConnections(" + connectionSet + 284 ", " + subject + ", " + cxRequest + ")"); 285 286 String userName; 287 String mode = "Unified"; 288 289 if (cxRequest == null) 291 userName = this.userName; 292 else { 293 if (! (cxRequest instanceof ConnectionRequest)) { 294 if (out != null) 295 out.print("Provided ConnectionRequestInfo instance is not a JORAM object."); 296 throw new ResourceException ("Provided ConnectionRequestInfo instance " 297 + "is not a JORAM object."); 298 } 299 300 userName = ((ConnectionRequest) cxRequest).getUserName(); 301 302 if (cxRequest instanceof QueueConnectionRequest) 303 mode = "PTP"; 304 } 305 306 String hostName = this.hostName; 307 int serverPort = this.serverPort; 308 309 if (collocated) { 310 hostName = "localhost"; 311 serverPort = -1; 312 } 313 314 ManagedConnectionImpl managedCx = null; 315 boolean matching = false; 316 317 Iterator it = connectionSet.iterator(); 318 while (! matching && it.hasNext()) { 319 try { 320 managedCx = (ManagedConnectionImpl) it.next(); 321 matching = managedCx.matches(hostName, serverPort, userName, mode); 322 } 323 catch (ClassCastException exc) {} 324 } 325 326 if (matching) { 327 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 328 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, 329 this + " matchManagedConnections match " + managedCx); 330 managedCx.setLogWriter(out); 331 return managedCx; 332 } 333 return null; 334 } 335 336 337 public int hashCode() 338 { 339 return ("PTP:" 340 + hostName 341 + ":" 342 + serverPort 343 + "-" 344 + userName).hashCode(); 345 } 346 347 348 public boolean equals(Object o) 349 { 350 if (! (o instanceof ManagedQueueConnectionFactoryImpl)) 351 return false; 352 353 ManagedConnectionFactoryImpl other = (ManagedConnectionFactoryImpl) o; 354 355 boolean res = 356 hostName.equals(other.hostName) 357 && serverPort == other.serverPort 358 && userName.equals(other.userName); 359 360 if (AdapterTracing.dbgAdapter.isLoggable(BasicLevel.DEBUG)) 361 AdapterTracing.dbgAdapter.log(BasicLevel.DEBUG, 362 this + " equals = " + res); 363 return res; 364 } 365 } 366 | Popular Tags |