1 package com.ubermq.jms.client; 2 3 import com.ubermq.jms.client.impl.*; 4 import com.ubermq.jms.client.unicast.*; 5 import java.net.*; 6 import javax.jms.*; 7 8 12 public class UnicastConnectionFactory 13 extends AbstractConnectionFactory 14 implements java.io.Serializable , 15 javax.jms.TopicConnectionFactory , 16 javax.jms.QueueConnectionFactory 17 { 18 private final InternetConnectionDescriptor icd; 19 public static final long serialVersionUID = 1L; 20 21 33 public UnicastConnectionFactory(String url) 34 { 35 this.icd = FailoverConnectionDescriptor.parseFailoverSpec(url, com.ubermq.jms.common.MessageConstants.DEFAULT_PORT); 36 } 37 38 public UnicastConnectionFactory(URI uri) 39 { 40 this.icd = FailoverConnectionDescriptor.parseFailoverSpec(uri, com.ubermq.jms.common.MessageConstants.DEFAULT_PORT); 41 } 42 43 49 public UnicastConnectionFactory(String host, int port) 50 { 51 this.icd = new SimpleInternetConnectionDescriptor(host, port); 52 } 53 54 public javax.jms.Connection createConnection() throws JMSException 55 { 56 try { 57 return new UnicastConnection(icd); 58 } catch(Exception x) {throw new JMSException(x.toString());} 59 } 60 } 61 | Popular Tags |