com.caucho.jms.queue
Class AbstractTopic

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

All Implemented Interfaces:

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

Direct Known Subclasses:

EventTopic, FileTopic, HempTopic, MemoryTopic, PollingTopic, ServerTopic, XmppTopic

public abstract class AbstractTopic
extends AbstractDestination
implements Topic

Implements an abstract topic.

See Also:

Serialized Form

Field Summary

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

_messageFactory

Constructor Summary

AbstractTopic()

Method Summary

abstract void	closeSubscriber(AbstractQueue subscriber)
abstract AbstractQueue	createSubscriber(JmsSession session, java.lang.String name, boolean noLocal)
void	init()
void	postConstruct()
MessageImpl	receive(long timeout) Polls the next message from the store.
void	setTopicName(java.lang.String name)

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

acknowledge, addMessageAvailableListener, close, drainTo, drainTo, generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getReadConsumer, getTopicName, getUrl, getWriteSession, hasMessage, iterator, offer, offer, peek, poll, poll, put, receive, remainingCapacity, removeMessageAvailableListener, rollback, send, setName, setSerializationHandle, size, take, toString

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.Topic

getTopicName, toString

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

Constructor Detail

AbstractTopic

public AbstractTopic()

Method Detail

setTopicName

public void setTopicName(java.lang.String name)

init

public void init()

postConstruct

public void postConstruct()

receive

public MessageImpl receive(long timeout)

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

createSubscriber

public abstract AbstractQueue createSubscriber(JmsSession session,
                                               java.lang.String name,
                                               boolean noLocal)

closeSubscriber

public abstract void closeSubscriber(AbstractQueue subscriber)