org.openorb.notify.queue
public abstract class Puller extends NotifyThread
Constructor Summary | |
---|---|
Puller(String id, FilterableEventQueue queue, EventReceiver receiver, SupplierProxyManagement proxy, long pullThreadLatency, 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 |