public class PooledSession extends Object implements javax.jms.Session, javax.jms.TopicSession, javax.jms.QueueSession, javax.jms.XASession
Constructor and Description |
---|
PooledSession(SessionKey key,
SessionHolder sessionHolder,
org.apache.commons.pool.KeyedObjectPool<SessionKey,SessionHolder> sessionPool,
boolean transactional,
boolean anonymous) |
Modifier and Type | Method and Description |
---|---|
void |
addSessionEventListener(org.apache.activemq.jms.pool.PooledSessionEventListener listener) |
void |
close() |
void |
commit() |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue) |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
String selector) |
javax.jms.BytesMessage |
createBytesMessage() |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
String selector) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
String selector,
boolean noLocal) |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
String selector) |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
String name,
String selector,
boolean noLocal) |
javax.jms.MapMessage |
createMapMessage() |
javax.jms.Message |
createMessage() |
javax.jms.ObjectMessage |
createObjectMessage() |
javax.jms.ObjectMessage |
createObjectMessage(Serializable serializable) |
javax.jms.MessageProducer |
createProducer(javax.jms.Destination destination) |
javax.jms.TopicPublisher |
createPublisher(javax.jms.Topic topic) |
javax.jms.Queue |
createQueue(String s) |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue) |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue,
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,
String selector,
boolean local) |
javax.jms.TemporaryQueue |
createTemporaryQueue() |
javax.jms.TemporaryTopic |
createTemporaryTopic() |
javax.jms.TextMessage |
createTextMessage() |
javax.jms.TextMessage |
createTextMessage(String s) |
javax.jms.Topic |
createTopic(String s) |
int |
getAcknowledgeMode() |
javax.jms.Session |
getInternalSession() |
javax.jms.MessageListener |
getMessageListener() |
javax.jms.MessageProducer |
getMessageProducer() |
javax.jms.MessageProducer |
getMessageProducer(javax.jms.Destination destination) |
javax.jms.QueueSender |
getQueueSender() |
javax.jms.QueueSender |
getQueueSender(javax.jms.Queue destination) |
javax.jms.Session |
getSession() |
javax.jms.TopicPublisher |
getTopicPublisher() |
javax.jms.TopicPublisher |
getTopicPublisher(javax.jms.Topic destination) |
boolean |
getTransacted() |
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) |
String |
toString() |
void |
unsubscribe(String s) |
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 javax.jms.JMSException
close
in interface javax.jms.Session
javax.jms.JMSException
public void commit() throws javax.jms.JMSException
commit
in interface javax.jms.Session
commit
in interface javax.jms.XASession
javax.jms.JMSException
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
createBytesMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
createMapMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.Message createMessage() throws javax.jms.JMSException
createMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.ObjectMessage createObjectMessage(Serializable serializable) throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.Queue createQueue(String s) throws javax.jms.JMSException
createQueue
in interface javax.jms.QueueSession
createQueue
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
createStreamMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
createTemporaryQueue
in interface javax.jms.QueueSession
createTemporaryQueue
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
createTemporaryTopic
in interface javax.jms.Session
createTemporaryTopic
in interface javax.jms.TopicSession
javax.jms.JMSException
public void unsubscribe(String s) throws javax.jms.JMSException
unsubscribe
in interface javax.jms.Session
unsubscribe
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TextMessage createTextMessage(String s) throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.Topic createTopic(String s) throws javax.jms.JMSException
createTopic
in interface javax.jms.Session
createTopic
in interface javax.jms.TopicSession
javax.jms.JMSException
public int getAcknowledgeMode() throws javax.jms.JMSException
getAcknowledgeMode
in interface javax.jms.Session
javax.jms.JMSException
public boolean getTransacted() throws javax.jms.JMSException
getTransacted
in interface javax.jms.Session
getTransacted
in interface javax.jms.XASession
javax.jms.JMSException
public void recover() throws javax.jms.JMSException
recover
in interface javax.jms.Session
javax.jms.JMSException
public void rollback() throws javax.jms.JMSException
rollback
in interface javax.jms.Session
rollback
in interface javax.jms.XASession
javax.jms.JMSException
public XAResource getXAResource()
getXAResource
in interface javax.jms.XASession
public javax.jms.Session getSession()
getSession
in interface javax.jms.XASession
public void run()
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, String selector) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, String selector) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, String selector, boolean noLocal) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String selector) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
createDurableSubscriber
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String name, String selector, boolean noLocal) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
createDurableSubscriber
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface javax.jms.Session
javax.jms.JMSException
public void setMessageListener(javax.jms.MessageListener messageListener) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, String selector, boolean local) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, String selector) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.MessageProducer createProducer(javax.jms.Destination destination) throws javax.jms.JMSException
createProducer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.QueueSender createSender(javax.jms.Queue queue) throws javax.jms.JMSException
createSender
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic) throws javax.jms.JMSException
createPublisher
in interface javax.jms.TopicSession
javax.jms.JMSException
public javax.jms.Session getInternalSession() throws IllegalStateException
IllegalStateException
public javax.jms.MessageProducer getMessageProducer() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.MessageProducer getMessageProducer(javax.jms.Destination destination) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.QueueSender getQueueSender() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.QueueSender getQueueSender(javax.jms.Queue destination) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TopicPublisher getTopicPublisher() throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.TopicPublisher getTopicPublisher(javax.jms.Topic destination) throws javax.jms.JMSException
javax.jms.JMSException
public void setIsXa(boolean isXa)
protected void onConsumerClose(javax.jms.MessageConsumer consumer)
consumer
- the consumer which is being closedCopyright © 2005–2018 FuseSource, Corp.. All rights reserved.