eu.larkc.core.pluginManager.remote.Servlet.Tomcat
Class JeePluginManager

java.lang.Object
  eu.larkc.core.pluginManager.remote.Servlet.Tomcat.JeePluginManager

All Implemented Interfaces:

PluginManager

public class JeePluginManager
extends java.lang.Object
implements PluginManager

LocalPluginManager is a particular implementation of PluginManger that runs within a thread on a local machine. A pipeline made using LocalPluginManager's has a number of strongly type queues between each PluginManager that represent the input and output streams to and from the plugin in question.

Author:

Mick Kerrigan, Barry Bishop

Nested Class Summary

Nested classes/interfaces inherited from interface eu.larkc.core.pluginManager.PluginManager

PluginManager.Message

Constructor Summary

JeePluginManager(Plugin plugin, JeeResourceDescription resource)
Constructor that takes only the plugin as input (input and output queues have to be set later).

JeePluginManager(Plugin plugin, java.util.List<Queue<SetOfStatements>> theInputQueues, java.util.List<Queue<SetOfStatements>> theOutputQueues, JeeResourceDescription resource)
Constructor thats takes the input and output queues as input.

Method Summary

void	accept(PluginManager.Message message) Accept.
void	addInputQueue(Queue<SetOfStatements> inputQueue) This method adds an input queue to the list of input queues.
void	addOutputQueue(Queue<SetOfStatements> outputQueue) This method adds an output queue to the list of output queues.
void	addPrevious(PluginManager provider) Adds the previous plugin manager.
java.util.List<Queue<SetOfStatements>>	getInputQueues() This method returns the input queue of the manager.
PluginManager.Message	getNextControlMessage() This method enables the next control message that was sent to this PluginManager to be retrieved.
java.util.List<Queue<SetOfStatements>>	getOutputQueues() This method returns the output queues of the manager.
void	setInputQueues(java.util.List<Queue<SetOfStatements>> theInputQueues) This method sets the input queue of the manager.
void	setOutputQueues(java.util.List<Queue<SetOfStatements>> theOutputQueues) This method sets the output queues of the manager.
void	start() Start.
java.lang.String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

JeePluginManager

public JeePluginManager(Plugin plugin,
                        JeeResourceDescription resource)

Constructor that takes only the plugin as input (input and output queues have to be set later).

Parameters:

plugin - The plugin for which this manager is responsible

JeePluginManager

public JeePluginManager(Plugin plugin,
                        java.util.List<Queue<SetOfStatements>> theInputQueues,
                        java.util.List<Queue<SetOfStatements>> theOutputQueues,
                        JeeResourceDescription resource)

Constructor thats takes the input and output queues as input.

Parameters:

theInputQueues - The queues from which input messages will come from the previous plugin in the pipeline

theOutputQueues - The queues onto which output messages should be put to send them to the next plugin in the pipeline

plugin - The plugin for which this manager is responsible

Method Detail

getInputQueues

public java.util.List<Queue<SetOfStatements>> getInputQueues()

This method returns the input queue of the manager.

Specified by:

getInputQueues in interface PluginManager

Returns:

the input queue

setInputQueues

public void setInputQueues(java.util.List<Queue<SetOfStatements>> theInputQueues)

This method sets the input queue of the manager.

Specified by:

setInputQueues in interface PluginManager

Parameters:

theInputQueues - the input queues

getOutputQueues

public java.util.List<Queue<SetOfStatements>> getOutputQueues()

This method returns the output queues of the manager.

Specified by:

getOutputQueues in interface PluginManager

Returns:

the output queues

setOutputQueues

public void setOutputQueues(java.util.List<Queue<SetOfStatements>> theOutputQueues)

This method sets the output queues of the manager.

Specified by:

setOutputQueues in interface PluginManager

Parameters:

theOutputQueues - the output queues

accept

public void accept(PluginManager.Message message)

Accept.

Specified by:

accept in interface PluginManager

Parameters:

message - the message

See Also:

PluginManager.accept(eu.larkc.core.pluginManager.PluginManager.Message)

getNextControlMessage

public PluginManager.Message getNextControlMessage()

This method enables the next control message that was sent to this PluginManager to be retrieved.

Returns:

the next control message

addPrevious

public void addPrevious(PluginManager provider)

Adds the previous plugin manager.

Specified by:

addPrevious in interface PluginManager

Parameters:

provider - the provider

See Also:

PluginManager.addPrevious(eu.larkc.core.pluginManager.PluginManager)

start

public void start()

Start.

Specified by:

start in interface PluginManager

See Also:

PluginManager.start()

addInputQueue

public void addInputQueue(Queue<SetOfStatements> inputQueue)

Description copied from interface: PluginManager

This method adds an input queue to the list of input queues.

Specified by:

addInputQueue in interface PluginManager

Parameters:

inputQueue - the new input queue

addOutputQueue

public void addOutputQueue(Queue<SetOfStatements> outputQueue)

Description copied from interface: PluginManager

This method adds an output queue to the list of output queues.

Specified by:

addOutputQueue in interface PluginManager

Parameters:

outputQueue - the new output queue

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object