org.activemq
Class ActiveMQTopicSession
java.lang.Object
org.activemq.ActiveMQTopicSession
- All Implemented Interfaces:
- Runnable, Session, TopicSession
public class ActiveMQTopicSession
- extends Object
- implements TopicSession
A TopicSession implementation that throws IllegalStateExceptions
when Queue operations are attempted but which delegates
to another TopicSession for all other operations.
The ActiveMQSessions implement both Topic and Queue Sessions
methods but the spec states that TopicSession should throw Exceptions
if queue operations are attempted on it.
- Version:
- $Revision: 1.1.1.1 $
Method Summary |
void |
close()
|
void |
commit()
|
QueueBrowser |
createBrowser(Queue queue)
|
QueueBrowser |
createBrowser(Queue queue,
String messageSelector)
|
BytesMessage |
createBytesMessage()
|
MessageConsumer |
createConsumer(Destination destination)
|
MessageConsumer |
createConsumer(Destination destination,
String messageSelector)
|
MessageConsumer |
createConsumer(Destination destination,
String messageSelector,
boolean NoLocal)
|
TopicSubscriber |
createDurableSubscriber(Topic topic,
String name)
|
TopicSubscriber |
createDurableSubscriber(Topic topic,
String name,
String messageSelector,
boolean noLocal)
|
MapMessage |
createMapMessage()
|
Message |
createMessage()
|
ObjectMessage |
createObjectMessage()
|
ObjectMessage |
createObjectMessage(Serializable object)
|
MessageProducer |
createProducer(Destination destination)
|
TopicPublisher |
createPublisher(Topic topic)
|
Queue |
createQueue(String queueName)
|
StreamMessage |
createStreamMessage()
|
TopicSubscriber |
createSubscriber(Topic topic)
|
TopicSubscriber |
createSubscriber(Topic topic,
String messageSelector,
boolean noLocal)
|
TemporaryQueue |
createTemporaryQueue()
|
TemporaryTopic |
createTemporaryTopic()
|
TextMessage |
createTextMessage()
|
TextMessage |
createTextMessage(String text)
|
Topic |
createTopic(String topicName)
|
boolean |
equals(Object arg0)
|
int |
getAcknowledgeMode()
|
MessageListener |
getMessageListener()
|
TopicSession |
getNext()
|
boolean |
getTransacted()
|
int |
hashCode()
|
void |
recover()
|
void |
rollback()
|
void |
run()
|
void |
setMessageListener(MessageListener listener)
|
String |
toString()
|
void |
unsubscribe(String name)
|
ActiveMQTopicSession
public ActiveMQTopicSession(TopicSession 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 Session
- Parameters:
queue
-
- Returns:
-
- Throws:
JMSException
createBrowser
public QueueBrowser createBrowser(Queue queue,
String messageSelector)
throws JMSException
- 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
- Specified by:
createDurableSubscriber
in interface TopicSession
- 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
- Specified by:
createDurableSubscriber
in interface TopicSession
- 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
createPublisher
public TopicPublisher createPublisher(Topic topic)
throws JMSException
- Specified by:
createPublisher
in interface TopicSession
- Parameters:
topic
-
- Returns:
-
- Throws:
JMSException
createQueue
public Queue createQueue(String queueName)
throws JMSException
- Specified by:
createQueue
in interface Session
- Parameters:
queueName
-
- Returns:
-
- Throws:
JMSException
createStreamMessage
public StreamMessage createStreamMessage()
throws JMSException
- Specified by:
createStreamMessage
in interface Session
- Returns:
-
- Throws:
JMSException
createSubscriber
public TopicSubscriber createSubscriber(Topic topic)
throws JMSException
- Specified by:
createSubscriber
in interface TopicSession
- Parameters:
topic
-
- Returns:
-
- Throws:
JMSException
createSubscriber
public TopicSubscriber createSubscriber(Topic topic,
String messageSelector,
boolean noLocal)
throws JMSException
- Specified by:
createSubscriber
in interface TopicSession
- Parameters:
topic
- messageSelector
- noLocal
-
- Returns:
-
- Throws:
JMSException
createTemporaryQueue
public TemporaryQueue createTemporaryQueue()
throws JMSException
- Specified by:
createTemporaryQueue
in interface Session
- Returns:
-
- Throws:
JMSException
createTemporaryTopic
public TemporaryTopic createTemporaryTopic()
throws JMSException
- Specified by:
createTemporaryTopic
in interface Session
- Specified by:
createTemporaryTopic
in interface TopicSession
- 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
- Specified by:
createTopic
in interface TopicSession
- 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
- Specified by:
unsubscribe
in interface TopicSession
- Parameters:
name
-
- Throws:
JMSException
getNext
public TopicSession getNext()
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.