org.openorb.notify.queue
Class Puller

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

public abstract class Puller
extends NotifyThread

Author:
Shawn Boyce

Constructor Summary
Puller(java.lang.String id, FilterableEventQueue queue, EventReceiver receiver, SupplierProxyManagement proxy, long pullThreadLatency, org.apache.avalon.framework.logger.Logger logger)
          Default constructor
 
Method Summary
 void run()
          The run method waits for new events and pushes them in the queue
 void setConnectionActive(boolean isConnectionActive)
          This method sets the connection activity
 
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

Puller

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

Method Detail

setConnectionActive

public void setConnectionActive(boolean isConnectionActive)
This method sets the connection activity


run

public void run()
The run method waits for new events and pushes them in the queue