public class ManagedSessionProxy extends Object implements Session, QueueSession, TopicSession
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
ManagedSessionProxy(org.apache.activemq.ActiveMQSession session,
ManagedConnectionProxy connectionProxy) |
public ManagedSessionProxy(org.apache.activemq.ActiveMQSession session, ManagedConnectionProxy connectionProxy)
public void setUseSharedTxContext(boolean enable) throws JMSException
JMSException
public void close() throws JMSException
close
in interface Session
JMSException
public void cleanup() throws JMSException
JMSException
- if session proxy has a problempublic void commit() throws JMSException
commit
in interface Session
JMSException
public QueueBrowser createBrowser(Queue queue) throws JMSException
createBrowser
in interface QueueSession
createBrowser
in interface Session
queue
- JMSException
public QueueBrowser createBrowser(Queue queue, String messageSelector) throws JMSException
createBrowser
in interface QueueSession
createBrowser
in interface Session
queue
- messageSelector
- JMSException
public BytesMessage createBytesMessage() throws JMSException
createBytesMessage
in interface Session
JMSException
public MessageConsumer createConsumer(Destination destination) throws JMSException
createConsumer
in interface Session
destination
- JMSException
public MessageConsumer createConsumer(Destination destination, String messageSelector) throws JMSException
createConsumer
in interface Session
destination
- messageSelector
- JMSException
public MessageConsumer createConsumer(Destination destination, String messageSelector, boolean noLocal) throws JMSException
createConsumer
in interface Session
destination
- messageSelector
- noLocal
- JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String name) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in interface TopicSession
topic
- name
- JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String name, String messageSelector, boolean noLocal) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in interface TopicSession
topic
- name
- messageSelector
- noLocal
- 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 object) throws JMSException
createObjectMessage
in interface Session
object
- JMSException
public MessageProducer createProducer(Destination destination) throws JMSException
createProducer
in interface Session
destination
- JMSException
public Queue createQueue(String queueName) throws JMSException
createQueue
in interface QueueSession
createQueue
in interface Session
queueName
- 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 text) throws JMSException
createTextMessage
in interface Session
text
- JMSException
public Topic createTopic(String topicName) throws JMSException
createTopic
in interface Session
createTopic
in interface TopicSession
topicName
- 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 recover() throws JMSException
recover
in interface Session
JMSException
public void rollback() throws JMSException
rollback
in interface Session
JMSException
public void setMessageListener(MessageListener listener) throws JMSException
setMessageListener
in interface Session
listener
- JMSException
public void unsubscribe(String name) throws JMSException
unsubscribe
in interface Session
unsubscribe
in interface TopicSession
name
- JMSException
public QueueReceiver createReceiver(Queue queue) throws JMSException
createReceiver
in interface QueueSession
queue
- JMSException
public QueueReceiver createReceiver(Queue queue, String messageSelector) throws JMSException
createReceiver
in interface QueueSession
queue
- messageSelector
- JMSException
public QueueSender createSender(Queue queue) throws JMSException
createSender
in interface QueueSession
queue
- JMSException
public TopicPublisher createPublisher(Topic topic) throws JMSException
createPublisher
in interface TopicSession
topic
- JMSException
public TopicSubscriber createSubscriber(Topic topic) throws JMSException
createSubscriber
in interface TopicSession
topic
- JMSException
public TopicSubscriber createSubscriber(Topic topic, String messageSelector, boolean noLocal) throws JMSException
createSubscriber
in interface TopicSession
topic
- messageSelector
- noLocal
- JMSException
public void run()
run
in interface Runnable
run
in interface Session
Session.run()
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.