org.eclipse.hyades.logging.adapter.impl
Class ComponentBroker

java.lang.Object
  org.eclipse.hyades.logging.adapter.impl.ComponentBroker

All Implemented Interfaces:

IComponentBroker

public class ComponentBroker

extends java.lang.Object

implements IComponentBroker

Basic implementation of the IComponentBroker interface.

Constructor Summary

ComponentBroker(java.lang.String name, IContextListener listener)
ComponentBroker constructor

Method Summary

void	addEventConsumer(IComponent con) Adds the component that will be the consumer of the event data
void	flushAndTerminate() Flush the events left in the queue to the consumers and terminate the broker.
void	queueEvents(java.lang.Object[] obj) Push some events into the queues for processing
void	setNextBroker(IComponentBroker nextBroker) Set the next component broker
void	start() Start the component broker.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ComponentBroker

public ComponentBroker(java.lang.String name,
                       IContextListener listener)

ComponentBroker constructor

Parameters:

name - - name of component broker. Currently this name is not used.

listener - - Context listener

Method Detail

addEventConsumer

public void addEventConsumer(IComponent con)

Description copied from interface: IComponentBroker

Adds the component that will be the consumer of the event data

Specified by:

addEventConsumer in interface IComponentBroker

Parameters:

con - - consumer component of the data

setNextBroker

public void setNextBroker(IComponentBroker nextBroker)

Description copied from interface: IComponentBroker

Set the next component broker

Specified by:

setNextBroker in interface IComponentBroker

Parameters:

nextBroker - component broker

queueEvents

public void queueEvents(java.lang.Object[] obj)

Push some events into the queues for processing

Specified by:

queueEvents in interface IComponentBroker

Parameters:

obj - - array of event objects to add to the queue for processing

start

public void start()

Description copied from interface: IComponentBroker

Start the component broker.

Specified by:

start in interface IComponentBroker

flushAndTerminate

public void flushAndTerminate()
                       throws java.lang.InterruptedException

Description copied from interface: IComponentBroker

Flush the events left in the queue to the consumers and terminate the broker.

Specified by:

flushAndTerminate in interface IComponentBroker

Throws:

java.lang.InterruptedException