org.openorb.notify.queue
Class AnyPuller

java.lang.Object
  |
  +--org.openorb.notify.NotifyThread
        |
        +--org.openorb.notify.queue.Puller
              |
              +--org.openorb.notify.queue.AnyPuller

All Implemented Interfaces:

java.lang.Runnable, ThreadManagement

public class AnyPuller

extends Puller

Author:

Olivier Modica, Shawn Boyce

Constructor Summary

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

Method Summary

void	setSupplier(PullSupplier supplier) This method sets a supplier

Methods inherited from class org.openorb.notify.queue.Puller

run, setConnectionActive

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

AnyPuller

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

Default constructor

Method Detail

setSupplier

public void setSupplier(PullSupplier supplier)

This method sets a supplier