org.openorb.notify.queue
Class AnyPusher

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--org.openorb.notify.NotifyThread
              |
              +--org.openorb.notify.queue.Pusher
                    |
                    +--org.openorb.notify.queue.AnyPusher

All Implemented Interfaces:

java.lang.Runnable, ThreadManagement

public class AnyPusher

extends Pusher

Author:

Olivier Modica, Shawn Boyce

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

AnyPusher(java.lang.String id, FilterableEventQueue queue, ConsumerProxyManagement proxy, org.omg.CORBA.ORB orb, org.apache.avalon.framework.logger.Logger logger)
Default constructor

Method Summary

void	setConsumer(PushConsumer consumer) This method sets a consumer

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

pushEvent, run, setConnectionActive, stopThread

Methods inherited from class org.openorb.notify.NotifyThread

finishWorkAndStopThread, resumeThread, startThread, 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

AnyPusher

public AnyPusher(java.lang.String id,
                 FilterableEventQueue queue,
                 ConsumerProxyManagement proxy,
                 org.omg.CORBA.ORB orb,
                 org.apache.avalon.framework.logger.Logger logger)

Default constructor

Method Detail

setConsumer

public void setConsumer(PushConsumer consumer)

This method sets a consumer