public class InboundSessionProxy extends Object implements Session, QueueSession, TopicSession
Session
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.AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
InboundSessionProxy() |
public InboundSessionProxy()
public Session getSession() throws JMSException
JMSException
public QueueSession getQueueSession() throws JMSException
JMSException
public TopicSession getTopicSession() throws JMSException
JMSException
public InboundContext getSessionAndProducer() throws JMSException
JMSException
public MessageProducer createProducer(Destination destination) throws JMSException
createProducer
in interface Session
JMSException
public void close() throws JMSException
close
in interface Session
JMSException
public void commit() throws JMSException
commit
in interface Session
JMSException
public void rollback() throws JMSException
rollback
in interface Session
JMSException
public void recover() throws JMSException
recover
in interface Session
JMSException
public void run()
public QueueBrowser createBrowser(Queue queue) throws JMSException
createBrowser
in interface QueueSession
createBrowser
in interface Session
JMSException
public QueueBrowser createBrowser(Queue queue, String s) throws JMSException
createBrowser
in interface QueueSession
createBrowser
in interface Session
JMSException
public BytesMessage createBytesMessage() throws JMSException
createBytesMessage
in interface Session
JMSException
public MessageConsumer createConsumer(Destination destination) throws JMSException
createConsumer
in interface Session
JMSException
public MessageConsumer createConsumer(Destination destination, String s) throws JMSException
createConsumer
in interface Session
JMSException
public MessageConsumer createConsumer(Destination destination, String s, boolean b) throws JMSException
createConsumer
in interface Session
JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String s) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in interface TopicSession
JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String s, String s1, boolean b) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in interface TopicSession
JMSException
public MapMessage createMapMessage() throws JMSException
createMapMessage
in interface Session
JMSException
public Message createMessage() throws JMSException
createMessage
in interface Session
JMSException
public ObjectMessage createObjectMessage() throws JMSException
createObjectMessage
in interface Session
JMSException
public ObjectMessage createObjectMessage(Serializable serializable) throws JMSException
createObjectMessage
in interface Session
JMSException
public Queue createQueue(String s) throws JMSException
createQueue
in interface QueueSession
createQueue
in interface Session
JMSException
public StreamMessage createStreamMessage() throws JMSException
createStreamMessage
in interface Session
JMSException
public TemporaryQueue createTemporaryQueue() throws JMSException
createTemporaryQueue
in interface QueueSession
createTemporaryQueue
in interface Session
JMSException
public TemporaryTopic createTemporaryTopic() throws JMSException
createTemporaryTopic
in interface Session
createTemporaryTopic
in interface TopicSession
JMSException
public TextMessage createTextMessage() throws JMSException
createTextMessage
in interface Session
JMSException
public TextMessage createTextMessage(String s) throws JMSException
createTextMessage
in interface Session
JMSException
public Topic createTopic(String s) throws JMSException
createTopic
in interface Session
createTopic
in interface TopicSession
JMSException
public int getAcknowledgeMode() throws JMSException
getAcknowledgeMode
in interface Session
JMSException
public MessageListener getMessageListener() throws JMSException
getMessageListener
in interface Session
JMSException
public boolean getTransacted() throws JMSException
getTransacted
in interface Session
JMSException
public void setMessageListener(MessageListener messageListener) throws JMSException
setMessageListener
in interface Session
JMSException
public void unsubscribe(String s) throws JMSException
unsubscribe
in interface Session
unsubscribe
in interface TopicSession
JMSException
public QueueReceiver createReceiver(Queue queue) throws JMSException
createReceiver
in interface QueueSession
JMSException
public QueueReceiver createReceiver(Queue queue, String s) throws JMSException
createReceiver
in interface QueueSession
JMSException
public QueueSender createSender(Queue queue) throws JMSException
createSender
in interface QueueSession
JMSException
public TopicSubscriber createSubscriber(Topic topic) throws JMSException
createSubscriber
in interface TopicSession
JMSException
public TopicSubscriber createSubscriber(Topic topic, String s, boolean b) throws JMSException
createSubscriber
in interface TopicSession
JMSException
public TopicPublisher createPublisher(Topic topic) throws JMSException
createPublisher
in interface TopicSession
JMSException
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.