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
BindDataflow(DataflowExpression<T> expr, T message, java.util.UUID hostId)

Method Summary

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

Methods inherited from class groovyx.gpars.serial.SerialMsg

updateRemoteHost

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

BindDataflow

public 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

Specified by:

execute in class SerialMsg

Parameters:

conn - The connection object