org.lwes.listener
Class ThreadedEnqueuer

java.lang.Object
  org.lwes.listener.ThreadedEnqueuer

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

DatagramEnqueuer

public abstract class ThreadedEnqueuer
extends java.lang.Object
implements java.lang.Runnable

Field Summary

protected java.util.List<QueueElement>

queue

Constructor Summary

ThreadedEnqueuer()
Default constructor.

Method Summary

java.util.List<QueueElement>	getQueue() Returns the queue to use for this enqueuer
void	initialize() Default initialize() method.
void	run() Default run() method.
void	setQueue(java.util.List<QueueElement> queue) Sets the queue to use for this enqueuer.
void	shutdown() Default shutdown() method.

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected java.util.List<QueueElement> queue

Constructor Detail

ThreadedEnqueuer

public ThreadedEnqueuer()

Default constructor.

Method Detail

getQueue

public java.util.List<QueueElement> getQueue()

Returns the queue to use for this enqueuer

Returns:

the List queue

setQueue

public void setQueue(java.util.List<QueueElement> queue)

Sets the queue to use for this enqueuer. Warning: this List must be thread-synchronized!

Parameters:

queue - the thread-synchronized List element

initialize

public void initialize()
                throws java.io.IOException

Default initialize() method. Should be overridden by classes extending ThreadedEnqueuer.

Throws:

java.io.IOException

shutdown

public void shutdown()

Default shutdown() method. Should be overridden by classes extending ThreadedDequeuer.

run

public void run()

Default run() method. Should be overridden by classes extending ThreadedDequeuer.

Specified by:

run in interface java.lang.Runnable