groovyx.gpars.dataflow.remote

Class RemoteDataflows

java.lang.Object

groovyx.gpars.serial.SerialHandles

groovyx.gpars.remote.LocalHost

groovyx.gpars.dataflow.remote.RemoteDataflows

public final class RemoteDataflows
extends LocalHost

Remoting context for Dataflows. Manages serialization, publishing and retrieval.

Author:

Rafal Slawik

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowBroadcast>	publishedBroadcasts Stores DataflowBroadcasts published in context of this instance of RemoteDataflows.
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowQueue<?>>	publishedQueues Stores DataflowQueues published in context of this instance of RemoteDataflows.
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<?>>	publishedVariables Stores DataflowVariables published in context of this instance of RemoteDataflows.
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<RemoteDataflowBroadcast>>	remoteBroadcasts Stores promises to remote instances of DataflowBroadcasts.
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<RemoteDataflowQueue<?>>>	remoteQueues Stores promises to remote instances of DataflowQueues.
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<DataflowVariable>>	remoteVariables Stores promises to remote instances of DataflowVariables.

Fields inherited from class groovyx.gpars.remote.LocalHost

remoteHosts

Fields inherited from class groovyx.gpars.serial.SerialHandles

id

Constructor Summary

Constructors

Constructor and Description
RemoteDataflows()

Method Summary

Modifier and Type	Method and Description
static RemoteDataflows	create() Factory method for creating RemoteDataflows
<T> T	get(java.lang.Class<T> klass, java.lang.String name)
Promise<RemoteDataflowQueue<?>>	getDataflowQueue(java.lang.String host, int port, java.lang.String name) Retrieves DataflowQueue published under specified name on remote host.
Promise<DataflowReadChannel>	getReadChannel(java.lang.String host, int port, java.lang.String name) Retrieves DataflowReadChannel corresponding to DataflowBroadcast published under given name on remote host.
Promise<DataflowVariable>	getVariable(java.lang.String host, int port, java.lang.String name) Retrieves DataflowVariable published under specified name on remote host.
void	publish(DataflowBroadcast broadcastStream, java.lang.String name) Publishes DataflowBroadcast under given name.
void	publish(DataflowQueue<?> queue, java.lang.String name) Publishes DataflowQueue under given name.
void	publish(DataflowVariable<?> variable, java.lang.String name) Publishes DataflowVariable under given name.
<T> void	registerProxy(java.lang.Class<T> klass, java.lang.String name, T object)

Methods inherited from class groovyx.gpars.remote.LocalHost

disconnect, getPromise, getSerialHost, onDisconnect, startServer, stopServer

Methods inherited from class groovyx.gpars.serial.SerialHandles

add, finalizeHandle, get, getId, remove

Methods inherited from class java.lang.Object

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

Field Detail

publishedVariables

private final java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<?>> publishedVariables

Stores DataflowVariables published in context of this instance of RemoteDataflows.

remoteVariables

private final java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<DataflowVariable>> remoteVariables

Stores promises to remote instances of DataflowVariables.

publishedBroadcasts

private final java.util.concurrent.ConcurrentMap<java.lang.String,DataflowBroadcast> publishedBroadcasts

Stores DataflowBroadcasts published in context of this instance of RemoteDataflows.

remoteBroadcasts

private final java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<RemoteDataflowBroadcast>> remoteBroadcasts

Stores promises to remote instances of DataflowBroadcasts.

publishedQueues

private final java.util.concurrent.ConcurrentMap<java.lang.String,DataflowQueue<?>> publishedQueues

Stores DataflowQueues published in context of this instance of RemoteDataflows.

remoteQueues

private final java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<RemoteDataflowQueue<?>>> remoteQueues

Stores promises to remote instances of DataflowQueues.

Constructor Detail

RemoteDataflows

RemoteDataflows()

Method Detail

publish

public void publish(DataflowVariable<?> variable,
                    java.lang.String name)

Publishes DataflowVariable under given name. It overrides previously published variable if the same name is given.

Parameters:

variable - the variable to be published

name - the name under which variable is published

getVariable

public Promise<DataflowVariable> getVariable(java.lang.String host,
                                             int port,
                                             java.lang.String name)

Retrieves DataflowVariable published under specified name on remote host.

Parameters:

host - the address of remote host

port - the the port of remote host

name - the name under which variable was published

Returns:

promise of DataflowVariable

publish

public void publish(DataflowBroadcast broadcastStream,
                    java.lang.String name)

Publishes DataflowBroadcast under given name. It overrides previously published broadcast if the same name is given.

Parameters:

broadcastStream - the stream to be published

name - the name under which stream is published

getReadChannel

public Promise<DataflowReadChannel> getReadChannel(java.lang.String host,
                                                   int port,
                                                   java.lang.String name)

Retrieves DataflowReadChannel corresponding to DataflowBroadcast published under given name on remote host.

Parameters:

host - the address of remote host

port - the port of remote host

name - the name under which broadcast is published

Returns:

promise of DataflowReadChannel

publish

public void publish(DataflowQueue<?> queue,
                    java.lang.String name)

Publishes DataflowQueue under given name. It overrides previously published queue if the same name is given.

Parameters:

queue - the queue to be published

name - the name under which queue is published

getDataflowQueue

public Promise<RemoteDataflowQueue<?>> getDataflowQueue(java.lang.String host,
                                                        int port,
                                                        java.lang.String name)

Retrieves DataflowQueue published under specified name on remote host.

Parameters:

host - the address of remote host

port - the port of remote host

name - the name under which queue was published

Returns:

promise of RemoteDataflowQueue

create

public static RemoteDataflows create()

Factory method for creating RemoteDataflows

Returns:

new instance of RemoteDataflows

registerProxy

public <T> void registerProxy(java.lang.Class<T> klass,
                              java.lang.String name,
                              T object)

Specified by:

registerProxy in class LocalHost

get

public <T> T get(java.lang.Class<T> klass,
                 java.lang.String name)

Specified by:

get in class LocalHost