org.openorb.notify.queue
Class Puller
java.lang.Object
org.openorb.notify.NotifyThread
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
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 java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Puller
public Puller(java.lang.String id,
FilterableEventQueue queue,
EventReceiver receiver,
SupplierProxyManagement proxy,
long pullThreadLatency,
org.apache.avalon.framework.logger.Logger logger)
- Default constructor
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