com.caucho.jms.cluster
Class ClientTopicSubscriber

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue
          com.caucho.jms.queue.AbstractDestination
              com.caucho.jms.queue.AbstractQueue
                  com.caucho.jms.cluster.ClientTopicSubscriber

All Implemented Interfaces:

HandleAware, java.io.Serializable, java.lang.Iterable, java.util.Collection, java.util.concurrent.BlockingQueue, java.util.Queue, Destination

public class ClientTopicSubscriber
extends AbstractQueue

Subscribes to a topic

See Also:

Serialized Form

Field Summary

Fields inherited from class com.caucho.jms.queue.AbstractDestination

_messageFactory

Method Summary

MessageImpl	receive(boolean isAutoAck) Polls the next message from the store.
void	send(JmsSession session, MessageImpl msg, int priority, long timeout) Sends a message to the queue
java.lang.String	toString()

Methods inherited from class com.caucho.jms.queue.AbstractQueue

addListenerException, addMessageAvailableListener, close, getBrowserList, getConsumerCount, getListenerFailCountTotal, getListenerFailLastTime, getQueueSize, init, notifyMessageAvailable, postConstruct, removeMessageAvailableListener, setQueueName, startPoll, stopPoll

Methods inherited from class com.caucho.jms.queue.AbstractDestination

acknowledge, drainTo, drainTo, generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getReadConsumer, getTopicName, getUrl, getWriteSession, hasMessage, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, rollback, setName, setSerializationHandle, size, take

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface javax.jms.Queue

getQueueName

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, remove

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, removeAll, retainAll, toArray, toArray

Method Detail

send

public void send(JmsSession session,
                 MessageImpl msg,
                 int priority,
                 long timeout)

Description copied from class: AbstractDestination

Sends a message to the queue

Specified by:

send in class AbstractDestination

receive

public MessageImpl receive(boolean isAutoAck)
                    throws JMSException

Polls the next message from the store. If no message is available, wait for the timeout.

Overrides:

receive in class AbstractDestination

Parameters:

isAutoAck - if true, automatically acknowledge the message

Throws:

JMSException

toString

public java.lang.String toString()

Overrides:

toString in class AbstractDestination