org.openorb.notify.queue
Class SequencePuller

java.lang.Object
  extended by org.openorb.notify.NotifyThread
      extended by org.openorb.notify.queue.Puller
          extended by org.openorb.notify.queue.SequencePuller
All Implemented Interfaces:
java.lang.Runnable, ThreadManagement

public class SequencePuller
extends Puller

Author:
Olivier Modica, Shawn Boyce

Constructor Summary
SequencePuller(java.lang.String id, FilterableEventQueue queue, EventReceiver receiver, SupplierProxyManagement proxy, long pullThreadLatency, org.apache.avalon.framework.logger.Logger logger)
          Default constructor
 
Method Summary
 void setSupplier(SequencePullSupplier supplier)
          This method sets a supplier
 
Methods inherited from class org.openorb.notify.queue.Puller
run, setConnectionActive
 
Methods inherited from class org.openorb.notify.NotifyThread
finishWorkAndStopThread, getLogger, resumeThread, startThread, stopThread, suspendThread, toString
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

SequencePuller

public SequencePuller(java.lang.String id,
                      FilterableEventQueue queue,
                      EventReceiver receiver,
                      SupplierProxyManagement proxy,
                      long pullThreadLatency,
                      org.apache.avalon.framework.logger.Logger logger)
Default constructor

Method Detail

setSupplier

public void setSupplier(SequencePullSupplier supplier)
This method sets a supplier