org.objectweb.joram.client.jms
Class TopicSubscriber

java.lang.Object
  extended by org.objectweb.joram.client.jms.MessageConsumer
      extended by org.objectweb.joram.client.jms.TopicSubscriber
All Implemented Interfaces:
javax.jms.MessageConsumer, javax.jms.TopicSubscriber

public class TopicSubscriber
extends MessageConsumer
implements javax.jms.TopicSubscriber

Implements the javax.jms.TopicSubscriber interface.


Nested Class Summary
 
Nested classes/interfaces inherited from class org.objectweb.joram.client.jms.MessageConsumer
MessageConsumer.Closer
 
Field Summary
 
Fields inherited from class org.objectweb.joram.client.jms.MessageConsumer
dest, noLocal, queueMode, selector, sess, targetName
 
Constructor Summary
TopicSubscriber(Session sess, Destination topic, java.lang.String name, java.lang.String selector, boolean noLocal)
          Constructs a subscriber.
 
Method Summary
 boolean getNoLocal()
          API method.
 javax.jms.Topic getTopic()
          API method.
 java.lang.String toString()
          Returns a string view of this receiver.
 
Methods inherited from class org.objectweb.joram.client.jms.MessageConsumer
activateMessageInput, checkClosed, close, doClose, getMessageListener, getMessageSelector, getQueueMode, getTargetName, passivateMessageInput, receive, receive, receiveNoWait, setMessageListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.MessageConsumer
close, getMessageListener, getMessageSelector, receive, receive, receiveNoWait, setMessageListener
 

Constructor Detail

TopicSubscriber

TopicSubscriber(Session sess,
                Destination topic,
                java.lang.String name,
                java.lang.String selector,
                boolean noLocal)
          throws javax.jms.JMSException
Constructs a subscriber.

Parameters:
sess - The session the subscriber belongs to.
topic - The topic the subscriber subscribes to.
name - The subscription name, for durable subs only.
selector - The selector for filtering messages.
noLocal - true if the subscriber does not wish to consume messages published through the same connection.
Throws:
javax.jms.InvalidDestinationException - if an invalid destination is specified.
javax.jms.IllegalStateException - If the connection is broken.
javax.jms.JMSException - If the creation fails for any other reason.
Method Detail

toString

public java.lang.String toString()
Returns a string view of this receiver.

Overrides:
toString in class MessageConsumer

getNoLocal

public boolean getNoLocal()
                   throws javax.jms.JMSException
API method.

Specified by:
getNoLocal in interface javax.jms.TopicSubscriber
Throws:
javax.jms.IllegalStateException - If the subscriber is closed.
javax.jms.JMSException

getTopic

public javax.jms.Topic getTopic()
                         throws javax.jms.JMSException
API method.

Specified by:
getTopic in interface javax.jms.TopicSubscriber
Throws:
javax.jms.IllegalStateException - If the subscriber is closed.
javax.jms.JMSException


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.