org.openorb.notify.queue

Class Puller

public abstract class Puller extends NotifyThread

Author: Shawn Boyce

Constructor Summary
Puller(String id, FilterableEventQueue queue, EventReceiver receiver, SupplierProxyManagement proxy, long pullThreadLatency, Logger logger)
Default constructor
Method Summary
voidrun()
The run method waits for new events and pushes them in the queue
voidsetConnectionActive(boolean isConnectionActive)
This method sets the connection activity

Constructor Detail

Puller

public Puller(String id, FilterableEventQueue queue, EventReceiver receiver, SupplierProxyManagement proxy, long pullThreadLatency, Logger logger)
Default constructor

Method Detail

run

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

setConnectionActive

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