Class JMSConnectionFactory
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.protocol.jms.factory.JMSConnectionFactory
-
- All Implemented Interfaces:
javax.jms.ConnectionFactory
,javax.jms.QueueConnectionFactory
,javax.jms.TopicConnectionFactory
- Direct Known Subclasses:
CachedJMSConnectionFactory
public class JMSConnectionFactory extends Object implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory
use of factory server down and up jms spec transport.jms.MessageSelector isDurable
-
-
Field Summary
Fields Modifier and Type Field 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 Summary
Constructors Constructor Description JMSConnectionFactory(Properties properties)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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)
-
-
-
Field Detail
-
ctx
protected Context ctx
-
connectionFactory
protected javax.jms.ConnectionFactory connectionFactory
-
connectionFactoryString
protected String connectionFactoryString
-
destinationType
protected JMSConstants.JMSDestinationType destinationType
-
destinationName
protected String destinationName
-
transactedSession
protected boolean transactedSession
-
sessionAckMode
protected int sessionAckMode
-
jmsSpec
protected String jmsSpec
-
isDurable
protected boolean isDurable
-
noPubSubLocal
protected boolean noPubSubLocal
-
clientId
protected String clientId
-
subscriptionName
protected String subscriptionName
-
messageSelector
protected String messageSelector
-
isSharedSubscription
protected boolean isSharedSubscription
-
-
Constructor Detail
-
JMSConnectionFactory
public JMSConnectionFactory(Properties properties)
-
-
Method Detail
-
getConnectionFactory
public javax.jms.ConnectionFactory getConnectionFactory()
-
getConnection
public javax.jms.Connection getConnection()
-
createConnection
public javax.jms.Connection createConnection()
- Specified by:
createConnection
in interfacejavax.jms.ConnectionFactory
-
createConnection
public javax.jms.Connection createConnection(String userName, String password)
- Specified by:
createConnection
in interfacejavax.jms.ConnectionFactory
-
createQueueConnection
public javax.jms.QueueConnection createQueueConnection() throws javax.jms.JMSException
- Specified by:
createQueueConnection
in interfacejavax.jms.QueueConnectionFactory
- Throws:
javax.jms.JMSException
-
createQueueConnection
public javax.jms.QueueConnection createQueueConnection(String userName, String password) throws javax.jms.JMSException
- Specified by:
createQueueConnection
in interfacejavax.jms.QueueConnectionFactory
- Throws:
javax.jms.JMSException
-
createTopicConnection
public javax.jms.TopicConnection createTopicConnection() throws javax.jms.JMSException
- Specified by:
createTopicConnection
in interfacejavax.jms.TopicConnectionFactory
- Throws:
javax.jms.JMSException
-
createTopicConnection
public javax.jms.TopicConnection createTopicConnection(String userName, String password) throws javax.jms.JMSException
- Specified by:
createTopicConnection
in interfacejavax.jms.TopicConnectionFactory
- Throws:
javax.jms.JMSException
-
getDestination
public javax.jms.Destination getDestination(javax.jms.Session session)
-
createMessageConsumer
public javax.jms.MessageConsumer createMessageConsumer(javax.jms.Session session, javax.jms.Destination destination)
-
createProducer
public javax.jms.MessageProducer createProducer(javax.jms.Session session, javax.jms.Destination destination, Boolean isQueue) throws javax.jms.JMSException
This is a JMS spec independent method to create a MessageProducer. Please be cautious when making any changes- Parameters:
session
- JMS sessiondestination
- the DestinationisQueue
- is the Destination a queue?jmsSpec11
- should we use JMS 1.1 API ?- Returns:
- a MessageProducer to send messages to the given Destination
- Throws:
javax.jms.JMSException
- on errors, to be handled and logged by the caller
-
createDestination
public javax.jms.Destination createDestination(javax.jms.Session session, String destinationName)
-
getSession
public javax.jms.Session getSession(javax.jms.Connection connection)
-
createSession
protected javax.jms.Session createSession(javax.jms.Connection connection)
-
start
public void start(javax.jms.Connection connection)
-
stop
public void stop(javax.jms.Connection connection)
-
closeConnection
public boolean closeConnection(javax.jms.Connection connection)
-
getContext
public Context getContext()
-
getDestinationType
public JMSConstants.JMSDestinationType getDestinationType()
-
getConnectionFactoryString
public String getConnectionFactoryString()
-
isTransactedSession
public boolean isTransactedSession()
-
getSessionAckMode
public int getSessionAckMode()
-
createContext
public javax.jms.JMSContext createContext()
- Specified by:
createContext
in interfacejavax.jms.ConnectionFactory
-
createContext
public javax.jms.JMSContext createContext(int sessionMode)
- Specified by:
createContext
in interfacejavax.jms.ConnectionFactory
-
createContext
public javax.jms.JMSContext createContext(String userName, String password)
- Specified by:
createContext
in interfacejavax.jms.ConnectionFactory
-
-