org.openorb.notify.queue
Class StructuredPuller

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

public class StructuredPuller
extends Puller

Author:
Olivier Modica, Shawn Boyce

Constructor Summary
StructuredPuller(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(StructuredPullSupplier 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

StructuredPuller

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