Package org.apache.activemq.ra
Class InboundConnectionProxyFactory
java.lang.Object
org.apache.activemq.ra.InboundConnectionProxyFactory
- All Implemented Interfaces:
jakarta.jms.ConnectionFactory,jakarta.jms.QueueConnectionFactory,jakarta.jms.TopicConnectionFactory
public class InboundConnectionProxyFactory
extends Object
implements jakarta.jms.ConnectionFactory, jakarta.jms.QueueConnectionFactory, jakarta.jms.TopicConnectionFactory
A
ConnectionFactory implementation which creates connections which can
be used with the ActiveMQ JCA Resource Adapter to publish messages using the
same underlying JMS session that is used to dispatch messages.-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionjakarta.jms.Connectionjakarta.jms.ConnectioncreateConnection(String userName, String password) jakarta.jms.JMSContextjakarta.jms.JMSContextcreateContext(int sessionMode) jakarta.jms.JMSContextcreateContext(String userName, String password) jakarta.jms.JMSContextcreateContext(String userName, String password, int sessionMode) jakarta.jms.QueueConnectionjakarta.jms.QueueConnectioncreateQueueConnection(String userName, String password) jakarta.jms.TopicConnectionjakarta.jms.TopicConnectioncreateTopicConnection(String userName, String password)
-
Constructor Details
-
InboundConnectionProxyFactory
public InboundConnectionProxyFactory()
-
-
Method Details
-
createConnection
public jakarta.jms.Connection createConnection() throws jakarta.jms.JMSException- Specified by:
createConnectionin interfacejakarta.jms.ConnectionFactory- Throws:
jakarta.jms.JMSException
-
createConnection
public jakarta.jms.Connection createConnection(String userName, String password) throws jakarta.jms.JMSException - Specified by:
createConnectionin interfacejakarta.jms.ConnectionFactory- Throws:
jakarta.jms.JMSException
-
createQueueConnection
public jakarta.jms.QueueConnection createQueueConnection() throws jakarta.jms.JMSException- Specified by:
createQueueConnectionin interfacejakarta.jms.QueueConnectionFactory- Throws:
jakarta.jms.JMSException
-
createQueueConnection
public jakarta.jms.QueueConnection createQueueConnection(String userName, String password) throws jakarta.jms.JMSException - Specified by:
createQueueConnectionin interfacejakarta.jms.QueueConnectionFactory- Throws:
jakarta.jms.JMSException
-
createTopicConnection
public jakarta.jms.TopicConnection createTopicConnection() throws jakarta.jms.JMSException- Specified by:
createTopicConnectionin interfacejakarta.jms.TopicConnectionFactory- Throws:
jakarta.jms.JMSException
-
createTopicConnection
public jakarta.jms.TopicConnection createTopicConnection(String userName, String password) throws jakarta.jms.JMSException - Specified by:
createTopicConnectionin interfacejakarta.jms.TopicConnectionFactory- Throws:
jakarta.jms.JMSException
-
createContext
public jakarta.jms.JMSContext createContext()- Specified by:
createContextin interfacejakarta.jms.ConnectionFactory- Returns:
- Returns the JMSContext.
-
createContext
- Specified by:
createContextin interfacejakarta.jms.ConnectionFactory- Returns:
- Returns the JMSContext.
-
createContext
- Specified by:
createContextin interfacejakarta.jms.ConnectionFactory- Returns:
- Returns the JMSContext.
-
createContext
public jakarta.jms.JMSContext createContext(int sessionMode) - Specified by:
createContextin interfacejakarta.jms.ConnectionFactory- Returns:
- Returns the JMSContext.
-