jrun.jms.core.client
Class JmsTopicSession

jrun.jms.core.client.JmsTopicSession

public class JmsTopicSession

The JmsTopicSession extends JmsSession and implements TopicSession. It is a client side representation of a JMS session.

Version:

$Revision: 1.20 $ $Date: 2001/10/12 07:55:31 $

Author:

Jim Alateras

Method Summary

protected void	addPublisher(JmsTopicPublisher publisher) Add the specified publisher to the list of managed publishers.
protected void	addSubscriber(JmsTopicSubscriber subscriber, java.lang.String name) Add the specified subscriber to the list of managed subscribers.
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name)
javax.jms.TopicSubscriber	createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal)
javax.jms.TopicPublisher	createPublisher(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic)
javax.jms.TopicSubscriber	createSubscriber(javax.jms.Topic topic, java.lang.String selector, boolean noLocal)
javax.jms.TemporaryTopic	createTemporaryTopic()
javax.jms.Topic	createTopic(java.lang.String topicName)
protected void	removePublisher(JmsTopicPublisher publisher) Remove the specified publisher form the list of managed publishers.
protected void	removeSubscriber(JmsTopicSubscriber subscriber) Remove the specified subscriber form the list of managed subscribers.
void	unsubscribe(java.lang.String name)

Method Detail

createTopic

public javax.jms.Topic createTopic(java.lang.String topicName)
                            throws javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
                                           throws javax.jms.JMSException

createSubscriber

public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
                                                  java.lang.String selector,
                                                  boolean noLocal)
                                           throws javax.jms.JMSException

createDurableSubscriber

public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
                                                         java.lang.String name)
                                                  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

createPublisher

public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
                                         throws javax.jms.JMSException

createTemporaryTopic

public javax.jms.TemporaryTopic createTemporaryTopic()
                                              throws javax.jms.JMSException

unsubscribe

public void unsubscribe(java.lang.String name)
                 throws javax.jms.JMSException

addSubscriber

protected void addSubscriber(JmsTopicSubscriber subscriber,
                             java.lang.String name)
                      throws javax.jms.JMSException

Add the specified subscriber to the list of managed subscribers. It does not check for duplicates. It also registers the end point with the server.

The consumer name can be null for non-durable subscribers.

Parameters:

consumer - consumer to add

addPublisher

protected void addPublisher(JmsTopicPublisher publisher)
                     throws javax.jms.JMSException

Add the specified publisher to the list of managed publishers. It does not check for duplicates. It also registers the end point with the server.

If the publisher is for a temporary topic then we need to register this with connection. All temporary topic message processing happens locally

Parameters:

publisher - publisher to add

removeSubscriber

protected void removeSubscriber(JmsTopicSubscriber subscriber)
                         throws javax.jms.JMSException

Remove the specified subscriber form the list of managed subscribers. If it does exist then fail silently.

This method will not clean up the server side reciever until the session is closed.

Parameters:

subscriber - subscriber to remove

removePublisher

protected void removePublisher(JmsTopicPublisher publisher)
                        throws javax.jms.JMSException

Remove the specified publisher form the list of managed publishers. If it does exist then fail silently.

Parameters:

publisher - publisher to remove