org.jencks.pool
Class PooledSpringXASession
java.lang.Object
org.jencks.pool.PooledSpringXASession
- All Implemented Interfaces:
- java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession, javax.jms.XASession
public class PooledSpringXASession
- extends java.lang.Object
- implements 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 |
Fields inherited from interface javax.jms.Session |
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Fields inherited from interface javax.jms.Session |
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Constructor Summary |
PooledSpringXASession(javax.jms.XASession session,
org.apache.commons.pool.ObjectPool sessionPool)
|
Method Summary |
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)
|
void |
destroyAndRemoveFromPool()
If the Session goes into an unstable (unusable) state, then we want to
close it down and permanently remove it from the pool. |
int |
getAcknowledgeMode()
|
javax.jms.XASession |
getActualSession()
|
boolean |
getIgnoreClose()
|
javax.jms.MessageListener |
getMessageListener()
|
javax.jms.MessageProducer |
getMessageProducer()
|
javax.jms.QueueSender |
getQueueSender()
|
javax.jms.Session |
getSession()
|
javax.jms.TopicPublisher |
getTopicPublisher()
|
boolean |
getTransacted()
|
javax.transaction.xa.XAResource |
getXAResource()
|
void |
recover()
|
void |
rollback()
|
void |
run()
|
void |
setIgnoreClose(boolean ignoreClose)
|
void |
setMessageListener(javax.jms.MessageListener messageListener)
|
void |
unsubscribe(java.lang.String s)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PooledSpringXASession
public PooledSpringXASession(javax.jms.XASession session,
org.apache.commons.pool.ObjectPool sessionPool)
getIgnoreClose
public boolean getIgnoreClose()
setIgnoreClose
public void setIgnoreClose(boolean ignoreClose)
destroyAndRemoveFromPool
public void destroyAndRemoveFromPool()
- If the Session goes into an unstable (unusable) state, then we want to
close it down and permanently remove it from the pool.
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
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
- Specified by:
run
in interface javax.jms.Session
getXAResource
public javax.transaction.xa.XAResource getXAResource()
- Specified by:
getXAResource
in interface javax.jms.XASession
getSession
public javax.jms.Session getSession()
throws javax.jms.JMSException
- Specified by:
getSession
in interface javax.jms.XASession
- Throws:
javax.jms.JMSException
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
getActualSession
public javax.jms.XASession getActualSession()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getMessageProducer
public javax.jms.MessageProducer getMessageProducer()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getQueueSender
public javax.jms.QueueSender getQueueSender()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
getTopicPublisher
public javax.jms.TopicPublisher getTopicPublisher()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
Copyright © 2010 LogicBlaze, Inc.. All Rights Reserved.