org.openorb.notify.queue
Class StructuredPusher

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

All Implemented Interfaces:

java.lang.Runnable, ThreadManagement

public class StructuredPusher

extends Pusher

Author:

Olivier Modica, Shawn Boyce

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

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

Method Summary

void	setConsumer(StructuredPushConsumer 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

StructuredPusher

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

Default constructor

Method Detail

setConsumer

public void setConsumer(StructuredPushConsumer consumer)

This method sets a consumer