public interface ConnectionContext
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the connection
|
void |
createConnection(Properties props)
Create connection using properties
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Session session,
String topicName)
Creates consumer using session and topic name
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Session session,
String topicName,
String selector)
Creates consumer using session, topic name and selector
|
javax.jms.MessageProducer |
createProducer(javax.jms.Session session,
String topicName)
Creates producer using session and topic
|
javax.jms.Session |
createSession(int sessionOpts)
Creates session using the specified session opts
|
javax.jms.Session |
createThreadLocalSession(int sessionOpts)
Creates a threadlocal session using session opts
|
boolean |
isConnectionInitialized()
Checks whether connection is initialized or not
|
void |
setExceptionListener(javax.jms.ExceptionListener exceptionListener)
Set the exception Listener
|
void createConnection(Properties props) throws NamingException, javax.jms.JMSException
props
- the properties used for creating jndi contextjavax.jms.JMSException
NamingException
void setExceptionListener(javax.jms.ExceptionListener exceptionListener) throws javax.jms.JMSException
exceptionListener
- javax.jms.JMSException
boolean isConnectionInitialized()
javax.jms.Session createSession(int sessionOpts) throws javax.jms.JMSException
sessionOpts
- javax.jms.JMSException
javax.jms.MessageConsumer createConsumer(javax.jms.Session session, String topicName) throws javax.jms.JMSException
session
- topicName
- javax.jms.JMSException
javax.jms.MessageConsumer createConsumer(javax.jms.Session session, String topicName, String selector) throws javax.jms.JMSException
session
- topicName
- javax.jms.JMSException
javax.jms.MessageProducer createProducer(javax.jms.Session session, String topicName) throws javax.jms.JMSException
session
- topicName
- javax.jms.JMSException
javax.jms.Session createThreadLocalSession(int sessionOpts) throws javax.jms.JMSException
sessionOpts
- javax.jms.JMSException
void close()
Copyright © 2018 Apache Software Foundation. All rights reserved.