1 24 package org.objectweb.joram.client.jms.ha.tcp; 25 26 import org.objectweb.joram.client.jms.*; 27 28 32 public class XAHATcpConnectionFactory 33 extends org.objectweb.joram.client.jms.XAConnectionFactory { 34 35 38 public XAHATcpConnectionFactory(String url) { 39 super(url); 40 } 41 42 43 48 public javax.jms.XAConnection 49 createXAConnection(String name, String password) 50 throws javax.jms.JMSException { 51 HATcpConnection lc = new HATcpConnection( 52 params.getUrl(), params, name, password, reliableClass); 53 return new XAConnection(params, lc); 54 } 55 56 62 public static javax.jms.XAConnectionFactory create(String url) { 63 return create(url, "org.objectweb.joram.client.jms.tcp.ReliableTcpClient"); 64 } 65 66 73 public static javax.jms.XAConnectionFactory 74 create(String url, String reliableClass) { 75 XAHATcpConnectionFactory cf = new XAHATcpConnectionFactory(url); 76 cf.setReliableClass(reliableClass); 77 return cf; 78 } 79 } 80 | Popular Tags |