org.activemq
Class ActiveMQQueueSession
java.lang.Object
org.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 spec states that Queue session should throw Exceptions
if topic operations are attempted on it.
- Version:
- $Revision: 1.1.1.1 $
ActiveMQQueueSession
public ActiveMQQueueSession(QueueSession next)
close
public void close()
throws JMSException
- Specified by:
close
in interface Session
- Throws:
JMSException
commit
public void commit()
throws JMSException
- Specified by:
commit
in interface Session
- Throws:
JMSException
createBrowser
public QueueBrowser createBrowser(Queue queue)
throws JMSException
- Specified by:
createBrowser
in interface QueueSession
- Specified by:
createBrowser
in interface Session
- Parameters:
queue
-
- Returns:
-
- Throws:
JMSException
createBrowser
public QueueBrowser createBrowser(Queue queue,
String messageSelector)
throws JMSException
- Specified by:
createBrowser
in interface QueueSession
- Specified by:
createBrowser
in interface Session
- Parameters:
queue
- messageSelector
-
- Returns:
-
- Throws:
JMSException
createBytesMessage
public BytesMessage createBytesMessage()
throws JMSException
- Specified by:
createBytesMessage
in interface Session
- Returns:
-
- Throws:
JMSException
createConsumer
public MessageConsumer createConsumer(Destination destination)
throws JMSException
- Specified by:
createConsumer
in interface Session
- Parameters:
destination
-
- Returns:
-
- Throws:
JMSException
createConsumer
public MessageConsumer createConsumer(Destination destination,
String messageSelector)
throws JMSException
- Specified by:
createConsumer
in interface Session
- Parameters:
destination
- messageSelector
-
- Returns:
-
- Throws:
JMSException
createConsumer
public MessageConsumer createConsumer(Destination destination,
String messageSelector,
boolean NoLocal)
throws JMSException
- Specified by:
createConsumer
in interface Session
- Parameters:
destination
- messageSelector
- NoLocal
-
- Returns:
-
- Throws:
JMSException
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(Topic topic,
String name)
throws JMSException
- Specified by:
createDurableSubscriber
in interface Session
- Parameters:
topic
- name
-
- Returns:
-
- Throws:
JMSException
createDurableSubscriber
public TopicSubscriber createDurableSubscriber(Topic topic,
String name,
String messageSelector,
boolean noLocal)
throws JMSException
- Specified by:
createDurableSubscriber
in interface Session
- Parameters:
topic
- name
- messageSelector
- noLocal
-
- Returns:
-
- Throws:
JMSException
createMapMessage
public MapMessage createMapMessage()
throws JMSException
- Specified by:
createMapMessage
in interface Session
- Returns:
-
- Throws:
JMSException
createMessage
public Message createMessage()
throws JMSException
- Specified by:
createMessage
in interface Session
- Returns:
-
- Throws:
JMSException
createObjectMessage
public ObjectMessage createObjectMessage()
throws JMSException
- Specified by:
createObjectMessage
in interface Session
- Returns:
-
- Throws:
JMSException
createObjectMessage
public ObjectMessage createObjectMessage(Serializable object)
throws JMSException
- Specified by:
createObjectMessage
in interface Session
- Parameters:
object
-
- Returns:
-
- Throws:
JMSException
createProducer
public MessageProducer createProducer(Destination destination)
throws JMSException
- Specified by:
createProducer
in interface Session
- Parameters:
destination
-
- Returns:
-
- Throws:
JMSException
createQueue
public Queue createQueue(String queueName)
throws JMSException
- Specified by:
createQueue
in interface QueueSession
- Specified by:
createQueue
in interface Session
- Parameters:
queueName
-
- Returns:
-
- Throws:
JMSException
createReceiver
public QueueReceiver createReceiver(Queue queue)
throws JMSException
- Specified by:
createReceiver
in interface QueueSession
- Parameters:
queue
-
- Returns:
-
- Throws:
JMSException
createReceiver
public QueueReceiver createReceiver(Queue queue,
String messageSelector)
throws JMSException
- Specified by:
createReceiver
in interface QueueSession
- Parameters:
queue
- messageSelector
-
- Returns:
-
- Throws:
JMSException
createSender
public QueueSender createSender(Queue queue)
throws JMSException
- Specified by:
createSender
in interface QueueSession
- Parameters:
queue
-
- Returns:
-
- Throws:
JMSException
createStreamMessage
public StreamMessage createStreamMessage()
throws JMSException
- Specified by:
createStreamMessage
in interface Session
- Returns:
-
- Throws:
JMSException
createTemporaryQueue
public TemporaryQueue createTemporaryQueue()
throws JMSException
- Specified by:
createTemporaryQueue
in interface QueueSession
- Specified by:
createTemporaryQueue
in interface Session
- Returns:
-
- Throws:
JMSException
createTemporaryTopic
public TemporaryTopic createTemporaryTopic()
throws JMSException
- Specified by:
createTemporaryTopic
in interface Session
- Returns:
-
- Throws:
JMSException
createTextMessage
public TextMessage createTextMessage()
throws JMSException
- Specified by:
createTextMessage
in interface Session
- Returns:
-
- Throws:
JMSException
createTextMessage
public TextMessage createTextMessage(String text)
throws JMSException
- Specified by:
createTextMessage
in interface Session
- Parameters:
text
-
- Returns:
-
- Throws:
JMSException
createTopic
public Topic createTopic(String topicName)
throws JMSException
- Specified by:
createTopic
in interface Session
- Parameters:
topicName
-
- Returns:
-
- Throws:
JMSException
equals
public boolean equals(Object arg0)
- Overrides:
equals
in class Object
getAcknowledgeMode
public int getAcknowledgeMode()
throws JMSException
- Specified by:
getAcknowledgeMode
in interface Session
- Returns:
-
- Throws:
JMSException
getMessageListener
public MessageListener getMessageListener()
throws JMSException
- Specified by:
getMessageListener
in interface Session
- Returns:
-
- Throws:
JMSException
getTransacted
public boolean getTransacted()
throws JMSException
- Specified by:
getTransacted
in interface Session
- Returns:
-
- Throws:
JMSException
hashCode
public int hashCode()
- Overrides:
hashCode
in class Object
recover
public void recover()
throws JMSException
- Specified by:
recover
in interface Session
- Throws:
JMSException
rollback
public void rollback()
throws JMSException
- Specified by:
rollback
in interface Session
- Throws:
JMSException
run
public void run()
- Specified by:
run
in interface Runnable
- Specified by:
run
in interface Session
setMessageListener
public void setMessageListener(MessageListener listener)
throws JMSException
- Specified by:
setMessageListener
in interface Session
- Parameters:
listener
-
- Throws:
JMSException
toString
public String toString()
- Overrides:
toString
in class Object
unsubscribe
public void unsubscribe(String name)
throws JMSException
- Specified by:
unsubscribe
in interface Session
- Parameters:
name
-
- Throws:
JMSException
getNext
public QueueSession getNext()
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.