public class PooledSession extends Object implements Session, TopicSession, QueueSession, XASession
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
Constructor and Description |
---|
PooledSession(SessionKey key,
SessionHolder sessionHolder,
org.apache.commons.pool.KeyedObjectPool<SessionKey,SessionHolder> sessionPool,
boolean transactional,
boolean anonymous) |
public PooledSession(SessionKey key, SessionHolder sessionHolder, org.apache.commons.pool.KeyedObjectPool<SessionKey,SessionHolder> sessionPool, boolean transactional, boolean anonymous)
public void addSessionEventListener(org.apache.activemq.jms.pool.PooledSessionEventListener listener)
protected boolean isIgnoreClose()
protected void setIgnoreClose(boolean ignoreClose)
public void close() throws JMSException
close
in interface Session
JMSException
public void commit() throws JMSException
commit
in interface Session
commit
in interface XASession
JMSException
public BytesMessage createBytesMessage() throws JMSException
createBytesMessage
in interface Session
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 void unsubscribe(String s) throws JMSException
unsubscribe
in interface Session
unsubscribe
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 boolean getTransacted() throws JMSException
getTransacted
in interface Session
getTransacted
in interface XASession
JMSException
public void recover() throws JMSException
recover
in interface Session
JMSException
public void rollback() throws JMSException
rollback
in interface Session
rollback
in interface XASession
JMSException
public XAResource getXAResource()
getXAResource
in interface XASession
public Session getSession()
getSession
in interface XASession
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 selector) throws JMSException
createBrowser
in interface QueueSession
createBrowser
in interface Session
JMSException
public MessageConsumer createConsumer(Destination destination) throws JMSException
createConsumer
in interface Session
JMSException
public MessageConsumer createConsumer(Destination destination, String selector) throws JMSException
createConsumer
in interface Session
JMSException
public MessageConsumer createConsumer(Destination destination, String selector, boolean noLocal) throws JMSException
createConsumer
in interface Session
JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String selector) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in interface TopicSession
JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, String name, String selector, boolean noLocal) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in interface TopicSession
JMSException
public MessageListener getMessageListener() throws JMSException
getMessageListener
in interface Session
JMSException
public void setMessageListener(MessageListener messageListener) throws JMSException
setMessageListener
in interface Session
JMSException
public TopicSubscriber createSubscriber(Topic topic) throws JMSException
createSubscriber
in interface TopicSession
JMSException
public TopicSubscriber createSubscriber(Topic topic, String selector, boolean local) throws JMSException
createSubscriber
in interface TopicSession
JMSException
public QueueReceiver createReceiver(Queue queue) throws JMSException
createReceiver
in interface QueueSession
JMSException
public QueueReceiver createReceiver(Queue queue, String selector) throws JMSException
createReceiver
in interface QueueSession
JMSException
public MessageProducer createProducer(Destination destination) throws JMSException
createProducer
in interface Session
JMSException
public QueueSender createSender(Queue queue) throws JMSException
createSender
in interface QueueSession
JMSException
public TopicPublisher createPublisher(Topic topic) throws JMSException
createPublisher
in interface TopicSession
JMSException
public Session getInternalSession() throws IllegalStateException
IllegalStateException
public MessageProducer getMessageProducer() throws JMSException
JMSException
public MessageProducer getMessageProducer(Destination destination) throws JMSException
JMSException
public QueueSender getQueueSender() throws JMSException
JMSException
public QueueSender getQueueSender(Queue destination) throws JMSException
JMSException
public TopicPublisher getTopicPublisher() throws JMSException
JMSException
public TopicPublisher getTopicPublisher(Topic destination) throws JMSException
JMSException
public void setIsXa(boolean isXa)
protected void onConsumerClose(MessageConsumer consumer)
consumer
- the consumer which is being closedCopyright © 2005–2017 FuseSource, Corp.. All rights reserved.