com.caucho.jms.connection
Class TopicSubscriberImpl

java.lang.Object
  com.caucho.jms.connection.MessageConsumerImpl
      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