org.mule.modules.microsoftservicebus.amqp

Class ConnectionFactoryWrapper

java.lang.Object

org.mule.modules.microsoftservicebus.amqp.ConnectionFactoryWrapper

All Implemented Interfaces:

javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory

public class ConnectionFactoryWrapper
extends Object
implements javax.jms.ConnectionFactory, javax.jms.TopicConnectionFactory, javax.jms.QueueConnectionFactory

Constructor Summary

Constructors

Constructor and Description
ConnectionFactoryWrapper(org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl connectionFactoryImpl, AuthenticationContext authContext, Boolean disableCnCheck)
ConnectionFactoryWrapper(org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl connectionFactoryImpl, Boolean disableCnCheck)

Method Summary

Methods

Modifier and Type	Method and Description
javax.jms.Connection	createConnection()
org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl	createConnection(String username, String password)
javax.jms.QueueConnection	createQueueConnection()
javax.jms.QueueConnection	createQueueConnection(String userName, String password)
javax.jms.TopicConnection	createTopicConnection()
javax.jms.TopicConnection	createTopicConnection(String userName, String password)
void	injectCBSContextWithinTrackedConnections()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionFactoryWrapper

public ConnectionFactoryWrapper(org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl connectionFactoryImpl,
                        Boolean disableCnCheck)

ConnectionFactoryWrapper

public ConnectionFactoryWrapper(org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl connectionFactoryImpl,
                        AuthenticationContext authContext,
                        Boolean disableCnCheck)

Method Detail

createConnection

public org.apache.qpid.amqp_1_0.jms.impl.ConnectionImpl createConnection(String username,
                                                                String password)
                                                                  throws javax.jms.JMSException

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Throws:

javax.jms.JMSException

createConnection

public javax.jms.Connection createConnection()
                                      throws javax.jms.JMSException

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Throws:

javax.jms.JMSException

createQueueConnection

public javax.jms.QueueConnection createQueueConnection()
                                                throws javax.jms.JMSException

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Throws:

javax.jms.JMSException

createQueueConnection

public javax.jms.QueueConnection createQueueConnection(String userName,
                                              String password)
                                                throws javax.jms.JMSException

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Throws:

javax.jms.JMSException

createTopicConnection

public javax.jms.TopicConnection createTopicConnection()
                                                throws javax.jms.JMSException

Specified by:

createTopicConnection in interface javax.jms.TopicConnectionFactory

Throws:

javax.jms.JMSException

createTopicConnection

public javax.jms.TopicConnection createTopicConnection(String userName,
                                              String password)
                                                throws javax.jms.JMSException

Specified by:

createTopicConnection in interface javax.jms.TopicConnectionFactory

Throws:

javax.jms.JMSException

injectCBSContextWithinTrackedConnections

public void injectCBSContextWithinTrackedConnections()
                                              throws javax.jms.JMSException

Throws:

javax.jms.JMSException