org.openorb.notify.queue
Class StructuredPuller

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

All Implemented Interfaces:

java.lang.Runnable, ThreadManagement

public class StructuredPuller

extends Puller

Author:

Olivier Modica, Shawn Boyce

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

StructuredPuller(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(StructuredPullSupplier 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, resumeThread, startThread, stopThread, suspendThread

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StructuredPuller

public StructuredPuller(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(StructuredPullSupplier supplier)

This method sets a supplier