org.activemq.pool
Class PooledSession
java.lang.Object
org.activemq.pool.PooledSession
- All Implemented Interfaces:
- javax.jms.QueueSession, java.lang.Runnable, javax.jms.Session, javax.jms.TopicSession
- public class PooledSession
- extends java.lang.Object
- implements javax.jms.TopicSession, javax.jms.QueueSession
- Version:
- $Revision: 1.1 $
| Fields inherited from interface javax.jms.Session |
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
|
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)
|
int |
getAcknowledgeMode()
|
javax.jms.MessageListener |
getMessageListener()
|
ActiveMQMessageProducer |
getMessageProducer()
|
ActiveMQQueueSender |
getQueueSender()
|
protected ActiveMQSession |
getSession()
|
ActiveMQTopicPublisher |
getTopicPublisher()
|
boolean |
getTransacted()
|
void |
recover()
|
void |
rollback()
|
void |
run()
|
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 |
PooledSession
public PooledSession(ActiveMQSession aSession,
org.apache.commons.pool.ObjectPool sessionPool)
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
- 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.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.Session
- Throws:
javax.jms.JMSException
createTemporaryTopic
public javax.jms.TemporaryTopic createTemporaryTopic()
throws javax.jms.JMSException
- 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.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.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
- 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
- Throws:
javax.jms.JMSException
run
public void run()
- 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.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.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.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.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
getSession
protected ActiveMQSession getSession()
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
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.