public class ManagedConnectionProxy extends Object implements javax.jms.Connection, javax.jms.QueueConnection, javax.jms.TopicConnection, javax.jms.ExceptionListener
Constructor and Description |
---|
ManagedConnectionProxy(ActiveMQManagedConnection managedConnection,
javax.resource.spi.ConnectionRequestInfo info) |
Modifier and Type | Method and Description |
---|---|
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,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Queue queue,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createConnectionConsumer(javax.jms.Topic topic,
String messageSelector,
javax.jms.ServerSessionPool sessionPool,
int maxMessages) |
javax.jms.ConnectionConsumer |
createDurableConnectionConsumer(javax.jms.Topic topic,
String subscriptionName,
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) |
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(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() |
public ManagedConnectionProxy(ActiveMQManagedConnection managedConnection, javax.resource.spi.ConnectionRequestInfo info)
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 modejavax.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 modejavax.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 modejavax.jms.JMSException
- on errorpublic 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(String clientID) throws javax.jms.JMSException
setClientID
in interface javax.jms.Connection
clientID
- new clientIdjavax.jms.JMSException
public void setExceptionListener(javax.jms.ExceptionListener listener) throws javax.jms.JMSException
setExceptionListener
in interface javax.jms.Connection
listener
- new listenerjavax.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, 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, 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, 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, String subscriptionName, 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
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.