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
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

Constructor Detail

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

Default constructor

public void run()

The run method waits for new events and pushes them in the queue

public void setConnectionActive(boolean isConnectionActive)

This method sets the connection activity