Package org.apache.activemq.ra
Class InboundSessionProxy
- java.lang.Object
-
- org.apache.activemq.ra.InboundSessionProxy
-
- All Implemented Interfaces:
Runnable
,QueueSession
,Session
,TopicSession
public class InboundSessionProxy extends Object implements Session, QueueSession, TopicSession
ASession
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.
-
-
Field Summary
-
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
-
-
Constructor Summary
Constructors Constructor Description InboundSessionProxy()
-
Method Summary
-
-
-
Method Detail
-
getSession
public Session getSession() throws JMSException
- Throws:
JMSException
-
getQueueSession
public QueueSession getQueueSession() throws JMSException
- Throws:
JMSException
-
getTopicSession
public TopicSession getTopicSession() throws JMSException
- Throws:
JMSException
-
getSessionAndProducer
public InboundContext getSessionAndProducer() throws JMSException
- Throws:
JMSException
-
createProducer
public MessageProducer createProducer(Destination destination) throws JMSException
- Specified by:
createProducer
in interfaceSession
- Throws:
JMSException
-
close
public void close() throws JMSException
- Specified by:
close
in interfaceSession
- Throws:
JMSException
-
commit
public void commit() throws JMSException
- Specified by:
commit
in interfaceSession
- Throws:
JMSException
-
rollback
public void rollback() throws JMSException
- Specified by:
rollback
in interfaceSession
- Throws:
JMSException
-
recover
public void recover() throws JMSException
- Specified by:
recover
in interfaceSession
- Throws:
JMSException
-
run
public void run()
-
createBrowser
public QueueBrowser createBrowser(Queue queue) throws JMSException
- Specified by:
createBrowser
in interfaceQueueSession
- Specified by:
createBrowser
in interfaceSession
- Throws:
JMSException
-
createBrowser
public QueueBrowser createBrowser(Queue queue, String s) throws JMSException
- Specified by:
createBrowser
in interfaceQueueSession
- Specified by:
createBrowser
in interfaceSession
- Throws:
JMSException
-
createBytesMessage
public BytesMessage createBytesMessage() throws JMSException
- Specified by:
createBytesMessage
in interfaceSession
- Throws:
JMSException
-
createConsumer
public MessageConsumer createConsumer(Destination destination) throws JMSException
- Specified by:
createConsumer
in interfaceSession
- Throws:
JMSException
-
createConsumer
public MessageConsumer createConsumer(Destination destination, String s) throws JMSException
- Specified by:
createConsumer
in interfaceSession
- Throws:
JMSException
-
createConsumer
public MessageConsumer createConsumer(Destination destination, String s, boolean b) throws JMSException
- Specified by:
createConsumer
in interfaceSession
- Throws:
JMSException
-
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(Topic topic, String s) throws JMSException
- Specified by:
createDurableSubscriber
in interfaceSession
- Specified by:
createDurableSubscriber
in interfaceTopicSession
- Throws:
JMSException
-
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(Topic topic, String s, String s1, boolean b) throws JMSException
- Specified by:
createDurableSubscriber
in interfaceSession
- Specified by:
createDurableSubscriber
in interfaceTopicSession
- Throws:
JMSException
-
createMapMessage
public MapMessage createMapMessage() throws JMSException
- Specified by:
createMapMessage
in interfaceSession
- Throws:
JMSException
-
createMessage
public Message createMessage() throws JMSException
- Specified by:
createMessage
in interfaceSession
- Throws:
JMSException
-
createObjectMessage
public ObjectMessage createObjectMessage() throws JMSException
- Specified by:
createObjectMessage
in interfaceSession
- Throws:
JMSException
-
createObjectMessage
public ObjectMessage createObjectMessage(Serializable serializable) throws JMSException
- Specified by:
createObjectMessage
in interfaceSession
- Throws:
JMSException
-
createQueue
public Queue createQueue(String s) throws JMSException
- Specified by:
createQueue
in interfaceQueueSession
- Specified by:
createQueue
in interfaceSession
- Throws:
JMSException
-
createStreamMessage
public StreamMessage createStreamMessage() throws JMSException
- Specified by:
createStreamMessage
in interfaceSession
- Throws:
JMSException
-
createTemporaryQueue
public TemporaryQueue createTemporaryQueue() throws JMSException
- Specified by:
createTemporaryQueue
in interfaceQueueSession
- Specified by:
createTemporaryQueue
in interfaceSession
- Throws:
JMSException
-
createTemporaryTopic
public TemporaryTopic createTemporaryTopic() throws JMSException
- Specified by:
createTemporaryTopic
in interfaceSession
- Specified by:
createTemporaryTopic
in interfaceTopicSession
- Throws:
JMSException
-
createTextMessage
public TextMessage createTextMessage() throws JMSException
- Specified by:
createTextMessage
in interfaceSession
- Throws:
JMSException
-
createTextMessage
public TextMessage createTextMessage(String s) throws JMSException
- Specified by:
createTextMessage
in interfaceSession
- Throws:
JMSException
-
createTopic
public Topic createTopic(String s) throws JMSException
- Specified by:
createTopic
in interfaceSession
- Specified by:
createTopic
in interfaceTopicSession
- Throws:
JMSException
-
getAcknowledgeMode
public int getAcknowledgeMode() throws JMSException
- Specified by:
getAcknowledgeMode
in interfaceSession
- Throws:
JMSException
-
getMessageListener
public MessageListener getMessageListener() throws JMSException
- Specified by:
getMessageListener
in interfaceSession
- Throws:
JMSException
-
getTransacted
public boolean getTransacted() throws JMSException
- Specified by:
getTransacted
in interfaceSession
- Throws:
JMSException
-
setMessageListener
public void setMessageListener(MessageListener messageListener) throws JMSException
- Specified by:
setMessageListener
in interfaceSession
- Throws:
JMSException
-
unsubscribe
public void unsubscribe(String s) throws JMSException
- Specified by:
unsubscribe
in interfaceSession
- Specified by:
unsubscribe
in interfaceTopicSession
- Throws:
JMSException
-
createReceiver
public QueueReceiver createReceiver(Queue queue) throws JMSException
- Specified by:
createReceiver
in interfaceQueueSession
- Throws:
JMSException
-
createReceiver
public QueueReceiver createReceiver(Queue queue, String s) throws JMSException
- Specified by:
createReceiver
in interfaceQueueSession
- Throws:
JMSException
-
createSender
public QueueSender createSender(Queue queue) throws JMSException
- Specified by:
createSender
in interfaceQueueSession
- Throws:
JMSException
-
createSubscriber
public TopicSubscriber createSubscriber(Topic topic) throws JMSException
- Specified by:
createSubscriber
in interfaceTopicSession
- Throws:
JMSException
-
createSubscriber
public TopicSubscriber createSubscriber(Topic topic, String s, boolean b) throws JMSException
- Specified by:
createSubscriber
in interfaceTopicSession
- Throws:
JMSException
-
createPublisher
public TopicPublisher createPublisher(Topic topic) throws JMSException
- Specified by:
createPublisher
in interfaceTopicSession
- Throws:
JMSException
-
-