User: user57
Date: 01/07/20 19:05:47
Added: src/main/org/jboss/jms ConnectionFactoryHelper.java
Log:
o Adding a helper class which creates connections from a connection factory,
prefering xa connections if possible.
Revision Changes Path
1.1 jboss/src/main/org/jboss/jms/ConnectionFactoryHelper.java
Index: ConnectionFactoryHelper.java
===================================================================
/*
* JBoss, the OpenSource EJB server
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.jms;
import javax.jms.JMSException;
import javax.jms.Connection;
import javax.jms.QueueConnectionFactory;
import javax.jms.XAQueueConnectionFactory;
import javax.jms.TopicConnectionFactory;
import javax.jms.XATopicConnectionFactory;
import org.apache.log4j.Category;
/**
* A helper for creating connections from jms connection factories.
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Jason Dillon</a>
* @version $Revision: 1.1 $
*/
public class ConnectionFactoryHelper
{
/** Class logger. */
private static Category log =
Category.getInstance(ConnectionFactoryHelper.class);
/**
* Create a connection from the given factory. An XA connection will
* be created if possible.
*
* @param factory An object that implements QueueConnectionFactory,
* XAQueueConnectionFactory, TopicConnectionFactory or
* XATopicConnectionFactory.
* @param username The username to use or null for no user.
* @param password The password for the given username or null if no
* username was specified.
* @return A connection.
*
* @throws JMSException Failed to create connection.
* @throws IllegalArgumentException Factory is null or invalid.
*/
public static Connection createConnection(final Object factory,
final String username,
final String password)
throws JMSException
{
if (factory == null)
throw new IllegalArgumentException("factory is null");
Connection connection;
if (factory instanceof QueueConnectionFactory) {
QueueConnectionFactory qFactory = (QueueConnectionFactory)factory;
if (username != null) {
connection = qFactory.createQueueConnection(username, password);
}
else {
connection = qFactory.createQueueConnection();
}
log.debug("created QueueConnection: " + connection);
}
else if (factory instanceof XAQueueConnectionFactory) {
XAQueueConnectionFactory qFactory = (XAQueueConnectionFactory)factory;
if (username != null) {
connection = qFactory.createXAQueueConnection(username, password);
}
else {
connection = qFactory.createXAQueueConnection();
}
log.debug("created XAQueueConnection: " + connection);
}
else if (factory instanceof TopicConnectionFactory) {
TopicConnectionFactory tFactory = (TopicConnectionFactory)factory;
if (username != null) {
connection = tFactory.createTopicConnection(username, password);
}
else {
connection = tFactory.createTopicConnection();
}
log.debug("created TopicConnection: " + connection);
}
else if (factory instanceof XATopicConnectionFactory) {
XATopicConnectionFactory tFactory = (XATopicConnectionFactory)factory;
if (username != null) {
connection = tFactory.createXATopicConnection(username, password);
}
else {
connection = tFactory.createXATopicConnection();
}
log.debug("created XATopicConnection: " + connection);
}
else {
throw new IllegalArgumentException("factory is invalid");
}
return connection;
}
/**
* Create a connection from the given factory. An XA connection will
* be created if possible.
*
* @param factory An object that implements QueueConnectionFactory,
* XAQueueConnectionFactory, TopicConnectionFactory or
* XATopicConnectionFactory.
* @return A connection.
*
* @throws JMSException Failed to create connection.
* @throws IllegalArgumentException Factory is null or invalid.
*/
public static Connection createConnection(final Object factory)
throws JMSException
{
return createConnection(factory, null, null);
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
