org.apache.activemq.pool
Class PooledSession
java.lang.Object
org.apache.activemq.pool.PooledSession
- All Implemented Interfaces:
- java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession, javax.jms.XASession
public class PooledSession
- extends java.lang.Object
- implements javax.jms.Session, javax.jms.TopicSession, javax.jms.QueueSession, javax.jms.XASession
Fields inherited from interface javax.jms.Session |
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Method Summary |
void |
addTempDestEventListener(org.apache.activemq.pool.PooledSessionEventListener listener)
|
void |
close()
|
void |
commit()
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue)
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
java.lang.String selector)
|
javax.jms.BytesMessage |
createBytesMessage()
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination)
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
java.lang.String selector)
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
java.lang.String selector,
boolean noLocal)
|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String selector)
|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name,
java.lang.String selector,
boolean noLocal)
|
javax.jms.MapMessage |
createMapMessage()
|
javax.jms.Message |
createMessage()
|
javax.jms.ObjectMessage |
createObjectMessage()
|
javax.jms.ObjectMessage |
createObjectMessage(java.io.Serializable serializable)
|
javax.jms.MessageProducer |
createProducer(javax.jms.Destination destination)
|
javax.jms.TopicPublisher |
createPublisher(javax.jms.Topic topic)
|
javax.jms.Queue |
createQueue(java.lang.String s)
|
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue)
|
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue,
java.lang.String selector)
|
javax.jms.QueueSender |
createSender(javax.jms.Queue queue)
|
javax.jms.StreamMessage |
createStreamMessage()
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic)
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic,
java.lang.String selector,
boolean local)
|
javax.jms.TemporaryQueue |
createTemporaryQueue()
|
javax.jms.TemporaryTopic |
createTemporaryTopic()
|
javax.jms.TextMessage |
createTextMessage()
|
javax.jms.TextMessage |
createTextMessage(java.lang.String s)
|
javax.jms.Topic |
createTopic(java.lang.String s)
|
int |
getAcknowledgeMode()
|
ActiveMQSession |
getInternalSession()
|
javax.jms.MessageListener |
getMessageListener()
|
ActiveMQMessageProducer |
getMessageProducer()
|
ActiveMQQueueSender |
getQueueSender()
|
javax.jms.Session |
getSession()
|
ActiveMQTopicPublisher |
getTopicPublisher()
|
boolean |
getTransacted()
|
javax.transaction.xa.XAResource |
getXAResource()
|
protected boolean |
isIgnoreClose()
|
protected void |
onConsumerClose(javax.jms.MessageConsumer consumer)
Callback invoked when the consumer is closed. |
void |
recover()
|
void |
rollback()
|
void |
run()
|
protected void |
setIgnoreClose(boolean ignoreClose)
|
void |
setIsXa(boolean isXa)
|
void |
setMessageListener(javax.jms.MessageListener messageListener)
|
java.lang.String |
toString()
|
void |
unsubscribe(java.lang.String s)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
PooledSession
public PooledSession(ActiveMQSession aSession,
SessionPool sessionPool)
addTempDestEventListener
public void addTempDestEventListener(org.apache.activemq.pool.PooledSessionEventListener listener)
isIgnoreClose
protected boolean isIgnoreClose()
setIgnoreClose
protected void setIgnoreClose(boolean ignoreClose)
close
public void close()
throws javax.jms.JMSException
- Specified by:
close
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
commit
public void commit()
throws javax.jms.JMSException
- Specified by:
commit
in interface javax.jms.Session
- Specified by:
commit
in interface javax.jms.XASession
- Throws:
javax.jms.JMSException
createBytesMessage
public javax.jms.BytesMessage createBytesMessage()
throws javax.jms.JMSException
- Specified by:
createBytesMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createMapMessage
public javax.jms.MapMessage createMapMessage()
throws javax.jms.JMSException
- Specified by:
createMapMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createMessage
public javax.jms.Message createMessage()
throws javax.jms.JMSException
- Specified by:
createMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createObjectMessage
public javax.jms.ObjectMessage createObjectMessage()
throws javax.jms.JMSException
- Specified by:
createObjectMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createObjectMessage
public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable serializable)
throws javax.jms.JMSException
- Specified by:
createObjectMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createQueue
public javax.jms.Queue createQueue(java.lang.String s)
throws javax.jms.JMSException
- Specified by:
createQueue
in interface javax.jms.QueueSession
- Specified by:
createQueue
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createStreamMessage
public javax.jms.StreamMessage createStreamMessage()
throws javax.jms.JMSException
- Specified by:
createStreamMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTemporaryQueue
public javax.jms.TemporaryQueue createTemporaryQueue()
throws javax.jms.JMSException
- Specified by:
createTemporaryQueue
in interface javax.jms.QueueSession
- Specified by:
createTemporaryQueue
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTemporaryTopic
public javax.jms.TemporaryTopic createTemporaryTopic()
throws javax.jms.JMSException
- Specified by:
createTemporaryTopic
in interface javax.jms.Session
- Specified by:
createTemporaryTopic
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
unsubscribe
public void unsubscribe(java.lang.String s)
throws javax.jms.JMSException
- Specified by:
unsubscribe
in interface javax.jms.Session
- Specified by:
unsubscribe
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createTextMessage
public javax.jms.TextMessage createTextMessage()
throws javax.jms.JMSException
- Specified by:
createTextMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTextMessage
public javax.jms.TextMessage createTextMessage(java.lang.String s)
throws javax.jms.JMSException
- Specified by:
createTextMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTopic
public javax.jms.Topic createTopic(java.lang.String s)
throws javax.jms.JMSException
- Specified by:
createTopic
in interface javax.jms.Session
- Specified by:
createTopic
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
getAcknowledgeMode
public int getAcknowledgeMode()
throws javax.jms.JMSException
- Specified by:
getAcknowledgeMode
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
getTransacted
public boolean getTransacted()
throws javax.jms.JMSException
- Specified by:
getTransacted
in interface javax.jms.Session
- Specified by:
getTransacted
in interface javax.jms.XASession
- Throws:
javax.jms.JMSException
recover
public void recover()
throws javax.jms.JMSException
- Specified by:
recover
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
rollback
public void rollback()
throws javax.jms.JMSException
- Specified by:
rollback
in interface javax.jms.Session
- Specified by:
rollback
in interface javax.jms.XASession
- Throws:
javax.jms.JMSException
getXAResource
public javax.transaction.xa.XAResource getXAResource()
- Specified by:
getXAResource
in interface javax.jms.XASession
getSession
public javax.jms.Session getSession()
- Specified by:
getSession
in interface javax.jms.XASession
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
- Specified by:
run
in interface javax.jms.Session
createBrowser
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue)
throws javax.jms.JMSException
- Specified by:
createBrowser
in interface javax.jms.QueueSession
- Specified by:
createBrowser
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createBrowser
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
java.lang.String selector)
throws javax.jms.JMSException
- Specified by:
createBrowser
in interface javax.jms.QueueSession
- Specified by:
createBrowser
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination)
throws javax.jms.JMSException
- Specified by:
createConsumer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
java.lang.String selector)
throws javax.jms.JMSException
- Specified by:
createConsumer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination,
java.lang.String selector,
boolean noLocal)
throws javax.jms.JMSException
- Specified by:
createConsumer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
java.lang.String selector)
throws javax.jms.JMSException
- Specified by:
createDurableSubscriber
in interface javax.jms.Session
- Specified by:
createDurableSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name,
java.lang.String selector,
boolean noLocal)
throws javax.jms.JMSException
- Specified by:
createDurableSubscriber
in interface javax.jms.Session
- Specified by:
createDurableSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
getMessageListener
public javax.jms.MessageListener getMessageListener()
throws javax.jms.JMSException
- Specified by:
getMessageListener
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
setMessageListener
public void setMessageListener(javax.jms.MessageListener messageListener)
throws javax.jms.JMSException
- Specified by:
setMessageListener
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createSubscriber
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
throws javax.jms.JMSException
- Specified by:
createSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createSubscriber
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
java.lang.String selector,
boolean local)
throws javax.jms.JMSException
- Specified by:
createSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createReceiver
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
throws javax.jms.JMSException
- Specified by:
createReceiver
in interface javax.jms.QueueSession
- Throws:
javax.jms.JMSException
createReceiver
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
java.lang.String selector)
throws javax.jms.JMSException
- Specified by:
createReceiver
in interface javax.jms.QueueSession
- Throws:
javax.jms.JMSException
createProducer
public javax.jms.MessageProducer createProducer(javax.jms.Destination destination)
throws javax.jms.JMSException
- Specified by:
createProducer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createSender
public javax.jms.QueueSender createSender(javax.jms.Queue queue)
throws javax.jms.JMSException
- Specified by:
createSender
in interface javax.jms.QueueSession
- Throws:
javax.jms.JMSException
createPublisher
public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
throws javax.jms.JMSException
- Specified by:
createPublisher
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
onConsumerClose
protected void onConsumerClose(javax.jms.MessageConsumer consumer)
- Callback invoked when the consumer is closed.
This is used to keep track of an explicit closed consumer created by this
session, by which we know do not need to keep track of the consumer, as
its already closed.
- Parameters:
consumer
- the consumer which is being closed
getInternalSession
public ActiveMQSession getInternalSession()
throws AlreadyClosedException
- Throws:
AlreadyClosedException
getMessageProducer
public ActiveMQMessageProducer getMessageProducer()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getQueueSender
public ActiveMQQueueSender getQueueSender()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getTopicPublisher
public ActiveMQTopicPublisher getTopicPublisher()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
setIsXa
public void setIsXa(boolean isXa)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 2005-2016. All Rights Reserved.