[Ubermq-commits] jms/src/com/ubermq/jms/client JMSInitialContextFactory.java,NONE,1.1 URLConnectionF
Brought to you by:
jimmyp
From: <ji...@us...> - 2003-03-27 15:19:46
|
Update of /cvsroot/ubermq/jms/src/com/ubermq/jms/client In directory sc8-pr-cvs1:/tmp/cvs-serv1542/src/com/ubermq/jms/client Modified Files: URLConnectionFactory.java UnicastTopicConnectionFactory.java Added Files: JMSInitialContextFactory.java Log Message: new funky InitialContext thing for simple, lightweight JNDI object creation --- NEW FILE: JMSInitialContextFactory.java --- package com.ubermq.jms.client; import com.ubermq.jms.client.impl.*; import java.util.*; import javax.naming.*; import javax.naming.spi.*; /** * A simple way to abstract out vendor-specific code in your applications. * Simply construct an InitialContext in the following way:<p> * * <code> * Hashtable env = new Hashtable(); * env.put(InitialContext.PROVIDER_URL, "ubermq://my-server"); * InitialContext ctx = new InitialContext(env); * ConnectionFactory f = (ConnectionFactory)ctx.lookup("connectionFactory"); * Topic myTopic = (Topic)ctx.lookup("topic:my-topic"); * </code> */ public final class JMSInitialContextFactory implements InitialContextFactory { public Context getInitialContext(Hashtable environment) throws NamingException { return new JMSInitialContext(environment); } } Index: URLConnectionFactory.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/URLConnectionFactory.java,v retrieving revision 1.1 retrieving revision 1.2 diff -C2 -d -r1.1 -r1.2 *** URLConnectionFactory.java 24 Jan 2003 15:34:43 -0000 1.1 --- URLConnectionFactory.java 27 Mar 2003 15:19:39 -0000 1.2 *************** *** 46,50 **** */ public class URLConnectionFactory ! implements ConnectionFactory, Serializable { private static final Map factories = new HashMap(); --- 46,50 ---- */ public class URLConnectionFactory ! implements ConnectionFactory, TopicConnectionFactory, QueueConnectionFactory, Serializable { private static final Map factories = new HashMap(); *************** *** 194,199 **** { Constructor singleCons = factory.getConstructor(FACTORY_SINGLE_SIGNATURE); ! TopicConnectionFactory delegate = ! (TopicConnectionFactory)singleCons.newInstance( new Object[] {uri} ); Utility.getLogger().fine("URL delegating to " + delegate.getClass()); --- 194,199 ---- { Constructor singleCons = factory.getConstructor(FACTORY_SINGLE_SIGNATURE); ! ConnectionFactory delegate = ! (ConnectionFactory)singleCons.newInstance( new Object[] {uri} ); Utility.getLogger().fine("URL delegating to " + delegate.getClass()); *************** *** 224,227 **** --- 224,259 ---- { return delegate.createConnection(p0, p1); + } + + /** + * @deprecated + */ + public TopicConnection createTopicConnection() throws JMSException + { + return ((TopicConnectionFactory)delegate).createTopicConnection(); + } + + /** + * @deprecated + */ + public QueueConnection createQueueConnection() throws JMSException + { + return ((QueueConnectionFactory)delegate).createQueueConnection(); + } + + /** + * @deprecated + */ + public TopicConnection createTopicConnection(String userName, String password) throws JMSException + { + return ((TopicConnectionFactory)delegate).createTopicConnection(userName, password); + } + + /** + * @deprecated + */ + public QueueConnection createQueueConnection(String userName, String password) throws JMSException + { + return ((QueueConnectionFactory)delegate).createQueueConnection(userName, password); } Index: UnicastTopicConnectionFactory.java =================================================================== RCS file: /cvsroot/ubermq/jms/src/com/ubermq/jms/client/UnicastTopicConnectionFactory.java,v retrieving revision 1.8 retrieving revision 1.9 diff -C2 -d -r1.8 -r1.9 *** UnicastTopicConnectionFactory.java 24 Jan 2003 15:34:43 -0000 1.8 --- UnicastTopicConnectionFactory.java 27 Mar 2003 15:19:40 -0000 1.9 *************** *** 1,5 **** package com.ubermq.jms.client; ! import com.ubermq.jms.client.impl.*; import com.ubermq.jms.client.unicast.*; import javax.jms.*; --- 1,5 ---- package com.ubermq.jms.client; ! import com.ubermq.jms.client.unicast.*; import javax.jms.*; |