groovyx.gpars.actor.remote

Class RemoteActors

java.lang.Object

groovyx.gpars.serial.SerialHandles

groovyx.gpars.remote.LocalHost

groovyx.gpars.actor.remote.RemoteActors

public final class RemoteActors
extends LocalHost

Remoting context for Actors. 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,Actor>	publishedActors Stores Actors published in context of this instance of RemoteActors.
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<Actor>>	remoteActors Stores promises to remote instances of Actors.

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	RemoteActors()

Method Summary

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

publishedActors

private final java.util.concurrent.ConcurrentMap<java.lang.String,Actor> publishedActors

Stores Actors published in context of this instance of RemoteActors.

remoteActors

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

Stores promises to remote instances of Actors.

Constructor Detail

RemoteActors

private RemoteActors()

Method Detail

publish

public void publish(Actor actor,
                    java.lang.String name)

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

Parameters:

actor - the Actor to be published

name - the name under which Actor is published

get

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

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

Returns:

promise of RemoteActor

create

public static RemoteActors 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