eu.larkc.core.pluginManager.remote.GAT
Class GatPluginManager

java.lang.Object
  eu.larkc.core.pluginManager.remote.GAT.GatPluginManager

All Implemented Interfaces:

PluginManager

public class GatPluginManager
extends java.lang.Object
implements PluginManager

GatPluginManager is a particular implementation of LocalPluginManger that executes on a remote GatResourceDescription by means of JavaGAT.

Author:

Alexey Cheptsov

Nested Class Summary

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

PluginManager.Message

Constructor Summary

GatPluginManager(Plugin plugin, GatResourceDescription gatDescription)
Constructor that takes only the plugin and the GatResourceDescription as input.

GatPluginManager(Plugin plugin, GatResourceDescription gatDescription, org.gridlab.gat.security.PasswordSecurityContext securityContext)
Extended version of the simple constructor that additionally takes securityContext as input.

GatPluginManager(Plugin plugin, java.util.List<Queue<SetOfStatements>> theInputQueues, java.util.List<Queue<SetOfStatements>> theOutputQueues, GatResourceDescription gatDescription)
Constructor that takes the input and output queues as well as and the GatResourceDescription 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

GatPluginManager

public GatPluginManager(Plugin plugin,
                        GatResourceDescription gatDescription)

Constructor that takes only the plugin and the GatResourceDescription as input.

Parameters:

plugin - The plugin for which this manager is responsible

GatResourceDescription - The GAT resource description

GatPluginManager

public GatPluginManager(Plugin plugin,
                        GatResourceDescription gatDescription,
                        org.gridlab.gat.security.PasswordSecurityContext securityContext)

Extended version of the simple constructor that additionally takes securityContext as input.

Parameters:

plugin - The plugin for which this manager is responsible

GatResourceDescription - The GAT resource description

securityContext - The Security Context

GatPluginManager

public GatPluginManager(Plugin plugin,
                        java.util.List<Queue<SetOfStatements>> theInputQueues,
                        java.util.List<Queue<SetOfStatements>> theOutputQueues,
                        GatResourceDescription gatDescription)

Constructor that takes the input and output queues as well as and the GatResourceDescription 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

GatResourceDescription - The GAT resource description

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