groovyx.gpars.dataflow.expression

Class DataflowExpression.BindDataflow<T>

java.lang.Object

groovyx.gpars.serial.SerialMsg

groovyx.gpars.dataflow.expression.DataflowExpression.BindDataflow<T>

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

DataflowExpression<T>

public static class DataflowExpression.BindDataflow<T>
extends SerialMsg

Represents a remote message binding a value to a remoted DataflowExpression

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
private DataflowExpression<T>	expr
private T	message
private static long	serialVersionUID

Fields inherited from class groovyx.gpars.serial.SerialMsg

hostId

Constructor Summary

Constructors

Constructor and Description
DataflowExpression.BindDataflow(DataflowExpression<T> expr, T message, java.util.UUID hostId)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(RemoteConnection conn) Performs the actual bind on the remote host

Methods inherited from class java.lang.Object

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

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

expr

private final DataflowExpression<T> expr

message

private final T message

Constructor Detail

DataflowExpression.BindDataflow

public DataflowExpression.BindDataflow(DataflowExpression<T> expr,
                               T message,
                               java.util.UUID hostId)

Parameters:

expr - The local DataflowExpression instance

message - The actual value to bind

hostId - The identification of the host to send the bind information to

Method Detail

execute

public void execute(RemoteConnection conn)

Performs the actual bind on the remote host

Overrides:

execute in class SerialMsg

Parameters:

conn - The connection object