com.levigo.jadice.server.nodes.worker

Interface StreamScriptContext

public interface StreamScriptContext

Scripts executed on a per stream basis (e.g. through the ScriptNode/ ScriptWorker) communicate with the server through this interface.

Method Summary

Methods

Modifier and Type	Method and Description
void	debug(String message, Object... args) Emit a debug message into the log if debugging is enabled.
void	error(com.levigo.util.log.qualified.MessageID messageId, Throwable cause, Object... args)
void	error(String message, Object... args) Emit an error message into the log.
void	error(String message, Throwable cause, Object... args) Emit an error message into the log.
void	fail(com.levigo.util.log.qualified.MessageID messageId, Throwable cause, Object... args)
void	fail(String message, Object... args) Abort the job giving the specified message as a reason.
void	fail(String message, Throwable cause, Object... args) Abort the job giving the specified message as a reason.
Job	getClientJob()
Stream	getNextInput() Get the next input stream.
Map<String,Serializable>	getParameters()
ServerJob	getServerJob()
ScriptWorker	getWorker()
boolean	hasNextInput()
void	info(String message, Object... args) Emit an info message into the log if info logging is enabled.
void	loopback(InputStream is, StreamDescriptor type) Loop back the given stream (described by the given stream descriptor) into the current node.
void	loopback(List<Stream> s, Node inputNode, Node outputNode)
void	loopback(Node input, Node output) Process a sub-pipeline defined by the input and output node and loop back its output into the current node.
void	loopback(Stream s) Loop back the given stream into the current node.
OutputStream	loopback(StreamDescriptor type)
void	loopback(Stream s, Node inputNode, Node outputNode)
void	output(InputStream is, StreamDescriptor type) Output the given stream (described by the given stream descriptor) to down-stream nodes.
void	output(List<Stream> s, Node inputNode, Node outputNode)
void	output(Node input, Node output) Process a sub-pipeline defined by the input and output node.
void	output(Stream s) Output the given stream to down-stream nodes.
OutputStream	output(StreamDescriptor type) Create an OutputStream described by the given stream descriptor which feeds into down-stream nodes.
void	output(Stream s, Node inputNode, Node outputNode)
StreamBundle	process(List<Stream> s, Node inputNode, Node outputNode)
StreamBundle	process(Node inputNode, Node outputNode) Execute the sub-pipeline defined by the input and output node and return the result as a StreamBundle.
StreamBundle	process(Stream s, Node inputNode, Node outputNode)
void	warn(com.levigo.util.log.qualified.MessageID messageId, Throwable cause, Object... args)
void	warn(String message, Object... args) Emit a warning message into the log.
void	warn(String message, Throwable cause, Object... args) Emit a warning message into the log.

Method Detail

getNextInput

Stream getNextInput()

Get the next input stream.

Returns:

the next input Stream or null if there are no more streams to be processed.

hasNextInput

boolean hasNextInput()

Returns:

true, if there is another Stream that waits for being processed

See Also:

getNextInput()

getWorker

ScriptWorker getWorker()

Returns:

The worker handling the current ScriptNode

getServerJob

ServerJob getServerJob()

Returns:

The ServerJob associated with this ScriptNode

getClientJob

Job getClientJob()

Returns:

The client-side Job associated with this ScriptNode

getParameters

Map<String,Serializable> getParameters()

Returns:

The script parameters supplied by the client.

output

void output(Node input,
          Node output)
            throws Throwable

Process a sub-pipeline defined by the input and output node. The pipeline between input and output node may be of arbitrary complexity, and may even encompass splits and merges. After its initialization, the current stream is piped into the input node of the sub-pipeline while the output of the output node is forwarded down-stream.

Parameters:

input -

output -

Throws:

Throwable

output

void output(InputStream is,
          StreamDescriptor type)
            throws IOException

Output the given stream (described by the given stream descriptor) to down-stream nodes.

Parameters:

is -

type -

Throws:

IOException

output

void output(Stream s)

Output the given stream to down-stream nodes.

Parameters:

s -

output

OutputStream output(StreamDescriptor type)
                    throws IOException

Create an OutputStream described by the given stream descriptor which feeds into down-stream nodes.

Parameters:

type -

Throws:

IOException

loopback

void loopback(Node input,
            Node output)
              throws Throwable

Process a sub-pipeline defined by the input and output node and loop back its output into the current node. The pipeline between input and output node may be of arbitrary complexity, and may even encompass splits and merges. After its initialization, the current stream is piped into the input node of the sub-pipeline while the output of the output node is looped back into the current node.

Parameters:

input -

output -

Throws:

Throwable

loopback

void loopback(InputStream is,
            StreamDescriptor type)
              throws IOException

Loop back the given stream (described by the given stream descriptor) into the current node.

Parameters:

is -

type -

Throws:

IOException

loopback

void loopback(Stream s)

Loop back the given stream into the current node.

Parameters:

s -

loopback

OutputStream loopback(StreamDescriptor type)
                      throws IOException

Parameters:

type -

Throws:

IOException

process

StreamBundle process(Node inputNode,
                   Node outputNode)
                     throws Throwable

Execute the sub-pipeline defined by the input and output node and return the result as a StreamBundle.

Parameters:

inputNode -

outputNode -

Returns:

the resulting bundle of the sub-pipeline

Throws:

Throwable

debug

void debug(String message,
         Object... args)

Emit a debug message into the log if debugging is enabled. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat.

Parameters:

message -

args -

info

void info(String message,
        Object... args)

Emit an info message into the log if info logging is enabled. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat.

Parameters:

message -

args -

warn

void warn(String message,
        Object... args)

Emit a warning message into the log. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat. The warning is also forwarded to any JobListeners of the current job.

Parameters:

message -

args -

warn

void warn(String message,
        Throwable cause,
        Object... args)

Emit a warning message into the log. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat. The warning is also forwarded to any JobListeners of the current job. The message is accompanied with the given Throwable causing the warning.

Parameters:

message -

cause -

args -

error

void error(String message,
         Object... args)

Emit an error message into the log. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat. The error message is also forwarded to any JobListeners of the current job.

Parameters:

message -

args -

error

void error(String message,
         Throwable cause,
         Object... args)

Emit an error message into the log. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat. The error message is also forwarded to any JobListeners of the current job. The message is accompanied with the given Throwable causing the error.

Parameters:

message -

cause -

args -

fail

void fail(String message,
        Object... args)

Abort the job giving the specified message as a reason. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat.

Parameters:

message -

args -

fail

void fail(String message,
        Throwable cause,
        Object... args)

Abort the job giving the specified message as a reason. The given arguments (if any) are interpolated into the message according to the syntax specified in MessageFormat. The message is accompanied with the given Throwable causing the error.

Parameters:

message -

cause -

args -

loopback

void loopback(Stream s,
            Node inputNode,
            Node outputNode)
              throws Throwable

Throws:

Throwable

output

void output(Stream s,
          Node inputNode,
          Node outputNode)
            throws Throwable

Throws:

Throwable

process

StreamBundle process(Stream s,
                   Node inputNode,
                   Node outputNode)
                     throws Throwable

Throws:

Throwable

loopback

void loopback(List<Stream> s,
            Node inputNode,
            Node outputNode)
              throws Throwable

Throws:

Throwable

output

void output(List<Stream> s,
          Node inputNode,
          Node outputNode)
            throws Throwable

Throws:

Throwable

process

StreamBundle process(List<Stream> s,
                   Node inputNode,
                   Node outputNode)
                     throws Throwable

Throws:

Throwable

error

void error(com.levigo.util.log.qualified.MessageID messageId,
         Throwable cause,
         Object... args)

fail

void fail(com.levigo.util.log.qualified.MessageID messageId,
        Throwable cause,
        Object... args)

warn

void warn(com.levigo.util.log.qualified.MessageID messageId,
        Throwable cause,
        Object... args)