|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.ra.ManagedConnectionProxy
public class ManagedConnectionProxy
Acts as a pass through proxy for a JMS Connection object. It intercepts events that are of interest of the ActiveMQManagedConnection.
Constructor Summary | |
---|---|
ManagedConnectionProxy(ActiveMQManagedConnection managedConnection)
|
Method Summary | |
---|---|
void |
cleanup()
Called by the ActiveMQManagedConnection to invalidate this proxy. |
void |
close()
Used to let the ActiveMQManagedConnection that this connection handel is not needed by the app. |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Destination destination,
java.lang.String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
java.lang.String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
|
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
java.lang.String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
|
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
java.lang.String subscriptionName,
java.lang.String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages)
|
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()
|
ActiveMQManagedConnection |
getManagedConnection()
|
javax.jms.ConnectionMetaData |
getMetaData()
|
void |
onException(javax.jms.JMSException e)
|
protected void |
sessionClosed(ManagedSessionProxy session)
|
void |
setClientID(java.lang.String clientID)
Sets client id on delegate |
void |
setExceptionListener(javax.jms.ExceptionListener listener)
sets exception listener on delegate |
void |
setUseSharedTxContext(boolean enable)
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ManagedConnectionProxy(ActiveMQManagedConnection managedConnection)
Method Detail |
---|
public void close() throws javax.jms.JMSException
close
in interface javax.jms.Connection
javax.jms.JMSException
public void cleanup()
public javax.jms.Session createSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createSession
in interface javax.jms.Connection
transacted
- Whether session is transactedacknowledgeMode
- session acknowledge mode
javax.jms.JMSException
- on errorprotected void sessionClosed(ManagedSessionProxy session)
public void setUseSharedTxContext(boolean enable) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.QueueSession createQueueSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createQueueSession
in interface javax.jms.QueueConnection
transacted
- Whether session is transactedacknowledgeMode
- session acknowledge mode
javax.jms.JMSException
- on errorpublic javax.jms.TopicSession createTopicSession(boolean transacted, int acknowledgeMode) throws javax.jms.JMSException
createTopicSession
in interface javax.jms.TopicConnection
transacted
- Whether session is transactedacknowledgeMode
- session acknowledge mode
javax.jms.JMSException
- on errorpublic java.lang.String getClientID() throws javax.jms.JMSException
getClientID
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ExceptionListener getExceptionListener() throws javax.jms.JMSException
getExceptionListener
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ConnectionMetaData getMetaData() throws javax.jms.JMSException
getMetaData
in interface javax.jms.Connection
javax.jms.JMSException
public void setClientID(java.lang.String clientID) throws javax.jms.JMSException
setClientID
in interface javax.jms.Connection
clientID
- new clientId
javax.jms.JMSException
public void setExceptionListener(javax.jms.ExceptionListener listener) throws javax.jms.JMSException
setExceptionListener
in interface javax.jms.Connection
listener
- new listener
javax.jms.JMSException
public void start() throws javax.jms.JMSException
start
in interface javax.jms.Connection
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface javax.jms.Connection
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Queue queue, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.QueueConnection
queue
- messageSelector
- sessionPool
- maxMessages
-
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Topic topic, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.TopicConnection
topic
- messageSelector
- sessionPool
- maxMessages
-
javax.jms.JMSException
public javax.jms.ConnectionConsumer createConnectionConsumer(javax.jms.Destination destination, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createConnectionConsumer
in interface javax.jms.Connection
destination
- messageSelector
- sessionPool
- maxMessages
-
javax.jms.JMSException
public javax.jms.ConnectionConsumer createDurableConnectionConsumer(javax.jms.Topic topic, java.lang.String subscriptionName, java.lang.String messageSelector, javax.jms.ServerSessionPool sessionPool, int maxMessages) throws javax.jms.JMSException
createDurableConnectionConsumer
in interface javax.jms.Connection
createDurableConnectionConsumer
in interface javax.jms.TopicConnection
topic
- subscriptionName
- messageSelector
- sessionPool
- maxMessages
-
javax.jms.JMSException
public ActiveMQManagedConnection getManagedConnection()
public void onException(javax.jms.JMSException e)
onException
in interface javax.jms.ExceptionListener
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |