com.caucho.jms.queue
Class PollingQueue<E>

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

All Implemented Interfaces:

HandleAware, MessageQueue<E>, AlarmListener, java.io.Serializable, java.lang.Iterable<E>, java.util.Collection<E>, java.util.concurrent.BlockingQueue<E>, java.util.EventListener, java.util.Queue<E>, Destination

Direct Known Subclasses:

JdbcQueue

public abstract class PollingQueue<E>
extends AbstractQueue<E>
implements AlarmListener

Implements an queue which polls the data periodically.

See Also:

Serialized Form

Constructor Summary

protected

PollingQueue()

Method Summary

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

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

acknowledge, addListenerException, addMessageCallback, close, drainTo, drainTo, getBrowserList, getConsumerCount, getListenerFailCountTotal, getListenerFailLastTime, getQueueSize, getReceiverCount, init, iterator, offer, offer, peek, poll, poll, postConstruct, put, receive, receive, receive, receiveEntry, receiveEntry, remainingCapacity, removeMessageCallback, rollback, setQueueName, size, take

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

generateMessageID, generateMessageID, getJMSDestination, getName, getQueueName, getTopicName, getUrl, hasMessage, send, setName, setSerializationHandle, 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.Queue

getQueueName, toString

Methods inherited from interface com.caucho.jms.queue.MessageQueue

send

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

PollingQueue

protected PollingQueue()

Method Detail

setPollPeriod

public void setPollPeriod(Period period)

startPoll

protected void startPoll()

stopPoll

protected 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

pollImpl

protected void pollImpl()