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

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractQueue<E>
          extended by com.caucho.jms.queue.AbstractDestination<E>
              extended by com.caucho.jms.queue.AbstractQueue<E>
                  extended by 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()