com.caucho.jms.connection
Class TopicSubscriberImpl

java.lang.Object
  extended by com.caucho.jms.connection.MessageConsumerImpl
      extended by com.caucho.jms.connection.TopicSubscriberImpl
All Implemented Interfaces:
MessageConsumer, TopicSubscriber

public class TopicSubscriberImpl
extends MessageConsumerImpl
implements TopicSubscriber

A basic topic subscriber


Field Summary
 
Fields inherited from class com.caucho.jms.connection.MessageConsumerImpl
_selector, _session
 
Method Summary
 void close()
          Closes the consumer.
 java.lang.String getMessageSelector()
          Returns the message consumer's selector.
 boolean getNoLocal()
          Returns true if local messages are not sent.
 Topic getTopic()
           
protected  Message receiveImpl(long timeout)
          Receives a message from the queue.
 
Methods inherited from class com.caucho.jms.connection.MessageConsumerImpl
addMessageCallback, getDestination, getMessageListener, getSelector, isActive, isClosed, notifyMessageAvailable, receive, receive, receiveNoWait, setMessageListener, setMessageListener, start, stop, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface javax.jms.MessageConsumer
getMessageListener, receive, receive, receiveNoWait, setMessageListener
 

Method Detail

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws JMSException
Returns the message consumer's selector.

Specified by:
getMessageSelector in interface MessageConsumer
Overrides:
getMessageSelector in class MessageConsumerImpl
Throws:
JMSException

getNoLocal

public boolean getNoLocal()
                   throws JMSException
Returns true if local messages are not sent.

Specified by:
getNoLocal in interface TopicSubscriber
Overrides:
getNoLocal in class MessageConsumerImpl
Throws:
JMSException

getTopic

public Topic getTopic()
               throws JMSException
Specified by:
getTopic in interface TopicSubscriber
Throws:
JMSException

receiveImpl

protected Message receiveImpl(long timeout)
                       throws JMSException
Description copied from class: MessageConsumerImpl
Receives a message from the queue.

Overrides:
receiveImpl in class MessageConsumerImpl
Throws:
JMSException

close

public void close()
Description copied from class: MessageConsumerImpl
Closes the consumer.

Specified by:
close in interface MessageConsumer
Overrides:
close in class MessageConsumerImpl