public class JMSConnectionFactory extends Object implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory
Modifier and Type | Field and Description |
---|---|
protected String |
clientId |
protected javax.jms.ConnectionFactory |
connectionFactory |
protected String |
connectionFactoryString |
protected Context |
ctx |
protected String |
destinationName |
protected JMSConstants.JMSDestinationType |
destinationType |
protected boolean |
isDurable |
protected boolean |
isSharedSubscription |
protected String |
jmsSpec |
protected String |
messageSelector |
protected boolean |
noPubSubLocal |
protected int |
sessionAckMode |
protected String |
subscriptionName |
protected boolean |
transactedSession |
Constructor and Description |
---|
JMSConnectionFactory(Properties properties) |
Modifier and Type | Method and Description |
---|---|
boolean |
closeConnection(javax.jms.Connection connection) |
javax.jms.Connection |
createConnection() |
javax.jms.Connection |
createConnection(String userName,
String password) |
javax.jms.JMSContext |
createContext() |
javax.jms.JMSContext |
createContext(int sessionMode) |
javax.jms.JMSContext |
createContext(String userName,
String password) |
javax.jms.JMSContext |
createContext(String userName,
String password,
int sessionMode) |
javax.jms.Destination |
createDestination(javax.jms.Session session,
String destinationName) |
javax.jms.MessageConsumer |
createMessageConsumer(javax.jms.Session session,
javax.jms.Destination destination) |
javax.jms.MessageProducer |
createProducer(javax.jms.Session session,
javax.jms.Destination destination,
Boolean isQueue)
This is a JMS spec independent method to create a MessageProducer.
|
javax.jms.QueueConnection |
createQueueConnection() |
javax.jms.QueueConnection |
createQueueConnection(String userName,
String password) |
protected javax.jms.Session |
createSession(javax.jms.Connection connection) |
javax.jms.TopicConnection |
createTopicConnection() |
javax.jms.TopicConnection |
createTopicConnection(String userName,
String password) |
javax.jms.Connection |
getConnection() |
javax.jms.ConnectionFactory |
getConnectionFactory() |
String |
getConnectionFactoryString() |
Context |
getContext() |
javax.jms.Destination |
getDestination(javax.jms.Session session) |
JMSConstants.JMSDestinationType |
getDestinationType() |
javax.jms.Session |
getSession(javax.jms.Connection connection) |
int |
getSessionAckMode() |
boolean |
isTransactedSession() |
void |
start(javax.jms.Connection connection) |
void |
stop(javax.jms.Connection connection) |
protected Context ctx
protected javax.jms.ConnectionFactory connectionFactory
protected String connectionFactoryString
protected JMSConstants.JMSDestinationType destinationType
protected String destinationName
protected boolean transactedSession
protected int sessionAckMode
protected String jmsSpec
protected boolean isDurable
protected boolean noPubSubLocal
protected String clientId
protected String subscriptionName
protected String messageSelector
protected boolean isSharedSubscription
public JMSConnectionFactory(Properties properties)
public javax.jms.ConnectionFactory getConnectionFactory()
public javax.jms.Connection getConnection()
public javax.jms.Connection createConnection()
createConnection
in interface javax.jms.ConnectionFactory
public javax.jms.Connection createConnection(String userName, String password)
createConnection
in interface javax.jms.ConnectionFactory
public javax.jms.QueueConnection createQueueConnection() throws javax.jms.JMSException
createQueueConnection
in interface javax.jms.QueueConnectionFactory
javax.jms.JMSException
public javax.jms.QueueConnection createQueueConnection(String userName, String password) throws javax.jms.JMSException
createQueueConnection
in interface javax.jms.QueueConnectionFactory
javax.jms.JMSException
public javax.jms.TopicConnection createTopicConnection() throws javax.jms.JMSException
createTopicConnection
in interface javax.jms.TopicConnectionFactory
javax.jms.JMSException
public javax.jms.TopicConnection createTopicConnection(String userName, String password) throws javax.jms.JMSException
createTopicConnection
in interface javax.jms.TopicConnectionFactory
javax.jms.JMSException
public javax.jms.Destination getDestination(javax.jms.Session session)
public javax.jms.MessageConsumer createMessageConsumer(javax.jms.Session session, javax.jms.Destination destination)
public javax.jms.MessageProducer createProducer(javax.jms.Session session, javax.jms.Destination destination, Boolean isQueue) throws javax.jms.JMSException
session
- JMS sessiondestination
- the DestinationisQueue
- is the Destination a queue?jmsSpec11
- should we use JMS 1.1 API ?javax.jms.JMSException
- on errors, to be handled and logged by the callerpublic javax.jms.Destination createDestination(javax.jms.Session session, String destinationName)
public javax.jms.Session getSession(javax.jms.Connection connection)
protected javax.jms.Session createSession(javax.jms.Connection connection)
public void start(javax.jms.Connection connection)
public void stop(javax.jms.Connection connection)
public boolean closeConnection(javax.jms.Connection connection)
public Context getContext()
public JMSConstants.JMSDestinationType getDestinationType()
public String getConnectionFactoryString()
public boolean isTransactedSession()
public int getSessionAckMode()
public javax.jms.JMSContext createContext()
createContext
in interface javax.jms.ConnectionFactory
public javax.jms.JMSContext createContext(int sessionMode)
createContext
in interface javax.jms.ConnectionFactory
public javax.jms.JMSContext createContext(String userName, String password)
createContext
in interface javax.jms.ConnectionFactory
Copyright © 2020 WSO2. All rights reserved.