com.caucho.jms.queue
Class PollingTopic

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

All Implemented Interfaces:

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

Direct Known Subclasses:

ClientTopic

public abstract class PollingTopic
extends AbstractTopic
implements AlarmListener

Implements an topic which polls the data periodically.

See Also:

Serialized Form

Field Summary

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

_messageFactory

Constructor Summary

protected

PollingTopic()

Method Summary

void	handleAlarm(Alarm alarm) Handles a callback from an alarm.
protected boolean	isPolling()
protected void	run()
void	setPollPeriod(Period period)
void	startPoll()
void	stopPoll()

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

closeSubscriber, createSubscriber, init, postConstruct, receive, setTopicName

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, toString, 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

PollingTopic

protected PollingTopic()

Method Detail

setPollPeriod

public void setPollPeriod(Period period)

isPolling

protected boolean isPolling()

startPoll

public void startPoll()

stopPoll

public void stopPoll()

handleAlarm

public void handleAlarm(Alarm alarm)

Description copied from interface: AlarmListener

Handles a callback from an alarm.

Specified by:

handleAlarm in interface AlarmListener

run

protected void run()