implementation for the generic JMS resource adapter
Implements the Connection
, TopicConnection
,
QueueConnection
interfaces.
- Author:
- Sivakumar Thyagarajan
Method Summary |
void |
associateConnection(ManagedConnection mc)
|
void |
cleanup()
|
void |
close()
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Destination dest,
java.lang.String msgSel,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
java.lang.String subName,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
java.lang.String subName,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
|
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
java.lang.String subName,
java.lang.String msgSel,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
|
javax.jms.QueueSession |
createQueueSession(boolean transacted,
int acknowledgeMode)
|
javax.jms.Session |
createSession(boolean transacted,
int acknowledgeMode)
|
javax.jms.TopicSession |
createTopicSession(boolean transacted,
int acknowledgeMode)
|
java.lang.String |
getClientID()
|
javax.jms.ExceptionListener |
getExceptionListener()
|
ManagedConnection |
getManagedConnection()
|
javax.jms.ConnectionMetaData |
getMetaData()
|
java.util.List |
getSessions()
|
boolean |
isClosed()
|
void |
removeSessionAdapter(SessionAdapter sessionToBeRemoved)
|
void |
setClientID(java.lang.String clientID)
|
void |
setExceptionListener(javax.jms.ExceptionListener excptLstnr)
|
void |
setInvalid()
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ConnectionHandle
public ConnectionHandle(ManagedConnection connection)
- Parameters:
connection
-
close
public void close()
throws javax.jms.JMSException
- Specified by:
close
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
start
public void start()
throws javax.jms.JMSException
- Specified by:
start
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
stop
public void stop()
throws javax.jms.JMSException
- Specified by:
stop
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
getClientID
public java.lang.String getClientID()
throws javax.jms.JMSException
- Specified by:
getClientID
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
setClientID
public void setClientID(java.lang.String clientID)
throws javax.jms.JMSException
- Specified by:
setClientID
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
getMetaData
public javax.jms.ConnectionMetaData getMetaData()
throws javax.jms.JMSException
- Specified by:
getMetaData
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
getExceptionListener
public javax.jms.ExceptionListener getExceptionListener()
throws javax.jms.JMSException
- Specified by:
getExceptionListener
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
setExceptionListener
public void setExceptionListener(javax.jms.ExceptionListener excptLstnr)
throws javax.jms.JMSException
- Specified by:
setExceptionListener
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
createSession
public javax.jms.Session createSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
- Specified by:
createSession
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination dest,
java.lang.String msgSel,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
throws javax.jms.JMSException
- Specified by:
createConnectionConsumer
in interface javax.jms.Connection
- Throws:
javax.jms.JMSException
createDurableConnectionConsumer
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic,
java.lang.String subName,
java.lang.String msgSel,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
throws javax.jms.JMSException
- Specified by:
createDurableConnectionConsumer
in interface javax.jms.Connection
- Specified by:
createDurableConnectionConsumer
in interface javax.jms.TopicConnection
- Throws:
javax.jms.JMSException
createTopicSession
public javax.jms.TopicSession createTopicSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
- Specified by:
createTopicSession
in interface javax.jms.TopicConnection
- Throws:
javax.jms.JMSException
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic,
java.lang.String subName,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
throws javax.jms.JMSException
- Specified by:
createConnectionConsumer
in interface javax.jms.TopicConnection
- Throws:
javax.jms.JMSException
createQueueSession
public javax.jms.QueueSession createQueueSession(boolean transacted,
int acknowledgeMode)
throws javax.jms.JMSException
- Specified by:
createQueueSession
in interface javax.jms.QueueConnection
- Throws:
javax.jms.JMSException
createConnectionConsumer
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue,
java.lang.String subName,
javax.jms.ServerSessionPool ssp,
int maxMsgs)
throws javax.jms.JMSException
- Specified by:
createConnectionConsumer
in interface javax.jms.QueueConnection
- Throws:
javax.jms.JMSException
cleanup
public void cleanup()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getManagedConnection
public ManagedConnection getManagedConnection()
associateConnection
public void associateConnection(ManagedConnection mc)
isClosed
public boolean isClosed()
removeSessionAdapter
public void removeSessionAdapter(SessionAdapter sessionToBeRemoved)
getSessions
public java.util.List getSessions()
setInvalid
public void setInvalid()