1 25 package org.objectweb.joram.client.jms.soap; 26 27 import org.objectweb.joram.client.jms.Connection; 28 import org.objectweb.joram.client.jms.FactoryParameters; 29 import org.objectweb.joram.client.jms.QueueConnection; 30 import org.objectweb.joram.client.jms.admin.AdminModule; 31 32 import java.util.Vector ; 33 34 import javax.naming.NamingException ; 35 import javax.naming.Reference ; 36 import javax.naming.StringRefAddr ; 37 38 42 public class QueueSoapConnectionFactory 43 extends org.objectweb.joram.client.jms.QueueConnectionFactory 44 { 45 53 public QueueSoapConnectionFactory(String host, int port, int timeout) 54 { 55 super(host, port); 56 params.cnxPendingTimer = timeout * 1000; 57 } 58 59 62 public QueueSoapConnectionFactory() 63 {} 64 65 71 public javax.jms.QueueConnection 72 createQueueConnection(String name, String password) 73 throws javax.jms.JMSException 74 { 75 return new QueueConnection(params, 76 new SoapConnection(params, name, password)); 77 } 78 79 85 public javax.jms.Connection createConnection(String name, String password) 86 throws javax.jms.JMSException 87 { 88 return new Connection(params, new SoapConnection(params, name, password)); 89 } 90 91 100 public static javax.jms.QueueConnectionFactory 101 create(String host, int port, int timeout) 102 { 103 return new QueueSoapConnectionFactory(host, port, timeout); 104 } 105 106 115 public static javax.jms.QueueConnectionFactory create(int timeout) 116 throws java.net.ConnectException 117 { 118 return create(AdminModule.getLocalHost(), 119 AdminModule.getLocalPort(), 120 timeout); 121 } 122 } 123 | Popular Tags |