Package org.apache.activemq
Class ActiveMQQueueSession
- java.lang.Object
-
- org.apache.activemq.ActiveMQQueueSession
-
- All Implemented Interfaces:
Runnable
,QueueSession
,Session
public class ActiveMQQueueSession extends Object implements QueueSession
A QueueSession implementation that throws IllegalStateExceptions when Topic operations are attempted but which delegates to another QueueSession for all other operations. The ActiveMQSessions implement both Topic and Queue Sessions methods but the specification states that Queue session should throw Exceptions if topic operations are attempted on it.
-
-
Field Summary
-
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
-
-
Constructor Summary
Constructors Constructor Description ActiveMQQueueSession(QueueSession next)
-
Method Summary
-
-
-
Constructor Detail
-
ActiveMQQueueSession
public ActiveMQQueueSession(QueueSession next)
-
-
Method Detail
-
close
public void close() throws JMSException
- Specified by:
close
in interfaceSession
- Throws:
JMSException
-
commit
public void commit() throws JMSException
- Specified by:
commit
in interfaceSession
- Throws:
JMSException
-
createBrowser
public QueueBrowser createBrowser(Queue queue) throws JMSException
- Specified by:
createBrowser
in interfaceQueueSession
- Specified by:
createBrowser
in interfaceSession
- Throws:
JMSException
-
createBrowser
public QueueBrowser createBrowser(Queue queue, String messageSelector) throws JMSException
- Specified by:
createBrowser
in interfaceQueueSession
- Specified by:
createBrowser
in interfaceSession
- Throws:
JMSException
-
createBytesMessage
public BytesMessage createBytesMessage() throws JMSException
- Specified by:
createBytesMessage
in interfaceSession
- Throws:
JMSException
-
createConsumer
public MessageConsumer createConsumer(Destination destination) throws JMSException
- Specified by:
createConsumer
in interfaceSession
- Throws:
JMSException
-
createConsumer
public MessageConsumer createConsumer(Destination destination, String messageSelector) throws JMSException
- Specified by:
createConsumer
in interfaceSession
- Throws:
JMSException
-
createConsumer
public MessageConsumer createConsumer(Destination destination, String messageSelector, boolean noLocal) throws JMSException
- Specified by:
createConsumer
in interfaceSession
- Throws:
JMSException
-
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(Topic topic, String name) throws JMSException
- Specified by:
createDurableSubscriber
in interfaceSession
- Throws:
JMSException
-
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(Topic topic, String name, String messageSelector, boolean noLocal) throws JMSException
- Specified by:
createDurableSubscriber
in interfaceSession
- Throws:
JMSException
-
createMapMessage
public MapMessage createMapMessage() throws JMSException
- Specified by:
createMapMessage
in interfaceSession
- Throws:
JMSException
-
createMessage
public Message createMessage() throws JMSException
- Specified by:
createMessage
in interfaceSession
- Throws:
JMSException
-
createObjectMessage
public ObjectMessage createObjectMessage() throws JMSException
- Specified by:
createObjectMessage
in interfaceSession
- Throws:
JMSException
-
createObjectMessage
public ObjectMessage createObjectMessage(Serializable object) throws JMSException
- Specified by:
createObjectMessage
in interfaceSession
- Throws:
JMSException
-
createProducer
public MessageProducer createProducer(Destination destination) throws JMSException
- Specified by:
createProducer
in interfaceSession
- Throws:
JMSException
-
createQueue
public Queue createQueue(String queueName) throws JMSException
- Specified by:
createQueue
in interfaceQueueSession
- Specified by:
createQueue
in interfaceSession
- Throws:
JMSException
-
createReceiver
public QueueReceiver createReceiver(Queue queue) throws JMSException
- Specified by:
createReceiver
in interfaceQueueSession
- Throws:
JMSException
-
createReceiver
public QueueReceiver createReceiver(Queue queue, String messageSelector) throws JMSException
- Specified by:
createReceiver
in interfaceQueueSession
- Throws:
JMSException
-
createSender
public QueueSender createSender(Queue queue) throws JMSException
- Specified by:
createSender
in interfaceQueueSession
- Throws:
JMSException
-
createStreamMessage
public StreamMessage createStreamMessage() throws JMSException
- Specified by:
createStreamMessage
in interfaceSession
- Throws:
JMSException
-
createTemporaryQueue
public TemporaryQueue createTemporaryQueue() throws JMSException
- Specified by:
createTemporaryQueue
in interfaceQueueSession
- Specified by:
createTemporaryQueue
in interfaceSession
- Throws:
JMSException
-
createTemporaryTopic
public TemporaryTopic createTemporaryTopic() throws JMSException
- Specified by:
createTemporaryTopic
in interfaceSession
- Throws:
JMSException
-
createTextMessage
public TextMessage createTextMessage() throws JMSException
- Specified by:
createTextMessage
in interfaceSession
- Throws:
JMSException
-
createTextMessage
public TextMessage createTextMessage(String text) throws JMSException
- Specified by:
createTextMessage
in interfaceSession
- Throws:
JMSException
-
createTopic
public Topic createTopic(String topicName) throws JMSException
- Specified by:
createTopic
in interfaceSession
- Throws:
JMSException
-
getAcknowledgeMode
public int getAcknowledgeMode() throws JMSException
- Specified by:
getAcknowledgeMode
in interfaceSession
- Throws:
JMSException
-
getMessageListener
public MessageListener getMessageListener() throws JMSException
- Specified by:
getMessageListener
in interfaceSession
- Throws:
JMSException
-
getTransacted
public boolean getTransacted() throws JMSException
- Specified by:
getTransacted
in interfaceSession
- Throws:
JMSException
-
recover
public void recover() throws JMSException
- Specified by:
recover
in interfaceSession
- Throws:
JMSException
-
rollback
public void rollback() throws JMSException
- Specified by:
rollback
in interfaceSession
- Throws:
JMSException
-
run
public void run()
-
setMessageListener
public void setMessageListener(MessageListener listener) throws JMSException
- Specified by:
setMessageListener
in interfaceSession
- Throws:
JMSException
-
unsubscribe
public void unsubscribe(String name) throws JMSException
- Specified by:
unsubscribe
in interfaceSession
- Throws:
JMSException
-
getNext
public QueueSession getNext()
-
-