org.lwes.listener
Class ThreadedEventListener

java.lang.Object
  org.lwes.listener.ThreadedEventListener

All Implemented Interfaces:

EventListener

Direct Known Subclasses:

DatagramEventListener

public abstract class ThreadedEventListener
extends java.lang.Object
implements EventListener

Field Summary

protected ThreadedProcessor

processor

Constructor Summary

ThreadedEventListener()
Default constructor.

Method Summary

void	addHandler(EventHandler handler) Add an EventHandler to handle events for processing.
ThreadedDequeuer	getDequeuer() Gets the dequeuer being used by this listener
ThreadedEnqueuer	getEnqueuer() Gets the enqueuer being used by this listener
void	initialize() Initializes this listener, and starts the processor threads
void	setDequeuer(ThreadedDequeuer dequeuer) Sets the dequeuer used by this listener
void	setEnqueuer(ThreadedEnqueuer enqueuer) Sets the enqueuer to use for this listener
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

processor

protected ThreadedProcessor processor

Constructor Detail

ThreadedEventListener

public ThreadedEventListener()

Default constructor.

Method Detail

getEnqueuer

public ThreadedEnqueuer getEnqueuer()

Gets the enqueuer being used by this listener

Returns:

the enqueuer

setEnqueuer

public void setEnqueuer(ThreadedEnqueuer enqueuer)

Sets the enqueuer to use for this listener

Parameters:

enqueuer - the enqueuer to set

getDequeuer

public ThreadedDequeuer getDequeuer()

Gets the dequeuer being used by this listener

Returns:

the dequeuer

setDequeuer

public void setDequeuer(ThreadedDequeuer dequeuer)

Sets the dequeuer used by this listener

Parameters:

dequeuer - the dequeuer to set

addHandler

public void addHandler(EventHandler handler)

Add an EventHandler to handle events for processing.

Specified by:

addHandler in interface EventListener

Parameters:

handler - the EventHandler to add

initialize

public void initialize()
                throws EventSystemException

Initializes this listener, and starts the processor threads

Throws:

EventSystemException - if there is a problem initializing the listener

shutdown

public void shutdown()
              throws EventSystemException

Throws:

EventSystemException