Package org.apache.activemq.ra
Class InboundConnectionProxy
- java.lang.Object
-
- org.apache.activemq.ra.InboundConnectionProxy
-
- All Implemented Interfaces:
Connection
,QueueConnection
,TopicConnection
public class InboundConnectionProxy extends Object implements Connection, QueueConnection, TopicConnection
AConnection
implementation which can be used with the ActiveMQ JCA Resource Adapter to publish messages using the same JMS session that is used to dispatch messages.
-
-
Constructor Summary
Constructors Constructor Description InboundConnectionProxy()
-
Method Summary
-
-
-
Method Detail
-
createSession
public Session createSession(boolean transacted, int ackMode) throws JMSException
- Specified by:
createSession
in interfaceConnection
- Throws:
JMSException
-
createQueueSession
public QueueSession createQueueSession(boolean transacted, int ackMode) throws JMSException
- Specified by:
createQueueSession
in interfaceQueueConnection
- Throws:
JMSException
-
createTopicSession
public TopicSession createTopicSession(boolean transacted, int ackMode) throws JMSException
- Specified by:
createTopicSession
in interfaceTopicConnection
- Throws:
JMSException
-
start
public void start() throws JMSException
- Specified by:
start
in interfaceConnection
- Throws:
JMSException
-
stop
public void stop() throws JMSException
- Specified by:
stop
in interfaceConnection
- Throws:
JMSException
-
close
public void close() throws JMSException
- Specified by:
close
in interfaceConnection
- Throws:
JMSException
-
getMetaData
public ConnectionMetaData getMetaData() throws JMSException
- Specified by:
getMetaData
in interfaceConnection
- Throws:
JMSException
-
getClientID
public String getClientID() throws JMSException
- Specified by:
getClientID
in interfaceConnection
- Throws:
JMSException
-
setClientID
public void setClientID(String s) throws JMSException
- Specified by:
setClientID
in interfaceConnection
- Throws:
JMSException
-
getExceptionListener
public ExceptionListener getExceptionListener() throws JMSException
- Specified by:
getExceptionListener
in interfaceConnection
- Throws:
JMSException
-
setExceptionListener
public void setExceptionListener(ExceptionListener exceptionListener) throws JMSException
- Specified by:
setExceptionListener
in interfaceConnection
- Throws:
JMSException
-
createConnectionConsumer
public ConnectionConsumer createConnectionConsumer(Destination destination, String s, ServerSessionPool serverSessionPool, int i) throws JMSException
- Specified by:
createConnectionConsumer
in interfaceConnection
- Throws:
JMSException
-
createDurableConnectionConsumer
public ConnectionConsumer createDurableConnectionConsumer(Topic topic, String s, String s1, ServerSessionPool serverSessionPool, int i) throws JMSException
- Specified by:
createDurableConnectionConsumer
in interfaceConnection
- Specified by:
createDurableConnectionConsumer
in interfaceTopicConnection
- Throws:
JMSException
-
createConnectionConsumer
public ConnectionConsumer createConnectionConsumer(Queue queue, String s, ServerSessionPool serverSessionPool, int i) throws JMSException
- Specified by:
createConnectionConsumer
in interfaceQueueConnection
- Throws:
JMSException
-
createConnectionConsumer
public ConnectionConsumer createConnectionConsumer(Topic topic, String s, ServerSessionPool serverSessionPool, int i) throws JMSException
- Specified by:
createConnectionConsumer
in interfaceTopicConnection
- Throws:
JMSException
-
createNotSupported
protected JMSException createNotSupported(String text)
-
-