org.openorb.notify.queue
Class AnyPuller

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

public class AnyPuller
extends Puller

Author:
Olivier Modica, Shawn Boyce

Constructor Summary
AnyPuller(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(PullSupplier 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

AnyPuller

public AnyPuller(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(PullSupplier supplier)
This method sets a supplier