groovyx.gpars.agent.remote

Class RemoteAgents

java.lang.Object

groovyx.gpars.serial.SerialHandles

groovyx.gpars.remote.LocalHost

groovyx.gpars.agent.remote.RemoteAgents

public final class RemoteAgents
extends LocalHost

Remoting context for Agents. 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,Agent<?>>	publishedAgents Stores Agents published in context of this instance of RemoteAgents.
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<RemoteAgent>>	remoteAgents Stores promises to remote instances of Agents.

Fields inherited from class groovyx.gpars.remote.LocalHost

remoteHosts

Fields inherited from class groovyx.gpars.serial.SerialHandles

id

Constructor Summary

Constructors

Modifier	Constructor and Description
private	RemoteAgents()

Method Summary

Modifier and Type	Method and Description
static RemoteAgents	create()
<T> T	get(java.lang.Class<T> klass, java.lang.String name)
Promise<RemoteAgent>	get(java.lang.String host, int port, java.lang.String name) Retrieves Agent published under specified name on remote host.
void	publish(Agent<?> agent, java.lang.String name) Publishes Agent 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

publishedAgents

private final java.util.concurrent.ConcurrentMap<java.lang.String,Agent<?>> publishedAgents

Stores Agents published in context of this instance of RemoteAgents.

remoteAgents

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

Stores promises to remote instances of Agents.

Constructor Detail

RemoteAgents

private RemoteAgents()

Method Detail

publish

public void publish(Agent<?> agent,
                    java.lang.String name)

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

Parameters:

agent - the Agent to be published

name - the name under which Agent is published

get

public Promise<RemoteAgent> get(java.lang.String host,
                                int port,
                                java.lang.String name)

Retrieves Agent 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 Agent was published

Returns:

promise of RemoteAgent

create

public static RemoteAgents create()

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