net.groboclown.eventbus.v1
Class ThreadedLocalEventDistributor

java.lang.Object
  |
  +--net.groboclown.eventbus.v1.ThreadedLocalEventDistributor

All Implemented Interfaces:

IEventDistributor, IObjectListener

public class ThreadedLocalEventDistributor

extends Object

implements IEventDistributor, IObjectListener

Sends events asynchronously in a separate event thread to all local listeners.

Version:

Alpha 0.9.0

Author:

Matt Albrecht

Field Summary

private LocalEventDistributor	localDistrib
private QueueThread	qthread

Constructor Summary

ThreadedLocalEventDistributor()
Default Constructor - mandatory.

Method Summary

void	initialize() Sets up the distributor after it has been created.
void	processObject(Object o) Deprecated. never called explicitly
void	sendEvent(EventBusObject ebo) Send the given event to wherever it needs to go.

Methods inherited from class java.lang.Object

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

Field Detail

qthread

private QueueThread qthread

localDistrib

private LocalEventDistributor localDistrib

Constructor Detail

ThreadedLocalEventDistributor

public ThreadedLocalEventDistributor()

Default Constructor - mandatory.

Method Detail

initialize

public void initialize()

Sets up the distributor after it has been created.

Specified by:

initialize in interface IEventDistributor

sendEvent

public void sendEvent(EventBusObject ebo)

Send the given event to wherever it needs to go.

Specified by:

sendEvent in interface IEventDistributor

processObject

public void processObject(Object o)

Deprecated. never called explicitly

Called when a queue listen event is sent to this listener.

Specified by:

processObject in interface IObjectListener