cloud.orbit.actors.runtime

Class LocalObjects

java.lang.Object

cloud.orbit.actors.runtime.LocalObjects

public class LocalObjects
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	LocalObjects.LocalObjectEntry<T>
static class	LocalObjects.NormalObjectEntry<T>
static class	LocalObjects.ObjectKey

Constructor Summary

Constructors

Constructor and Description
LocalObjects()

Method Summary

Modifier and Type	Method and Description
protected <T> LocalObjects.LocalObjectEntry	createLocalObjectEntry(RemoteReference<T> reference, T object) This method must be overridden by the stage to create proper entries for Actors and Stateless Actors
protected <T> RemoteReference<T>	createReference(NodeAddress address, Class<T> iClass, String objectId)
LocalObjects.LocalObjectEntry	findLocalActor(Actor actor)
LocalObjects.LocalObjectEntry	findLocalObject(NodeAddress address, int interfaceId, Object objectId)
LocalObjects.LocalObjectEntry	findLocalObjectByObject(Object object)
LocalObjects.LocalObjectEntry	findLocalObjectByReference(RemoteReference reference)
long	getLocalActorCount()
int	getLocalObjectCount()
<T> RemoteReference<T>	getOrAddLocalObjectReference(NodeAddress address, Class<T> iClass, String objectId, T object) Installs this remote object into this node with the given id.
void	remove(Object key, Object object)
Stream<Map.Entry<Object,LocalObjects.LocalObjectEntry>>	stream()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalObjects

public LocalObjects()

Method Detail

findLocalObject

public LocalObjects.LocalObjectEntry findLocalObject(NodeAddress address,
                                                     int interfaceId,
                                                     Object objectId)

findLocalObjectByReference

public LocalObjects.LocalObjectEntry findLocalObjectByReference(RemoteReference reference)

findLocalActor

public LocalObjects.LocalObjectEntry findLocalActor(Actor actor)

findLocalObjectByObject

public LocalObjects.LocalObjectEntry findLocalObjectByObject(Object object)

getOrAddLocalObjectReference

public <T> RemoteReference<T> getOrAddLocalObjectReference(NodeAddress address,
                                                           Class<T> iClass,
                                                           String objectId,
                                                           T object)

Installs this remote object into this node with the given id.

Type Parameters:

T - The type of reference class returned.

Parameters:

address - The local node address if this is a object that will not be registered in the directory

iClass - Hint to the framework about which remote interface this object represents. Can be null if there are no ambiguities.

objectId - Can be null, in this case the framework will choose an id.

object - The object to install

Returns:

a remote reference that can be sent to actors.

Throws:

IllegalArgumentException - if called twice with the same observer and different ids

createReference

protected <T> RemoteReference<T> createReference(NodeAddress address,
                                                 Class<T> iClass,
                                                 String objectId)

createLocalObjectEntry

protected <T> LocalObjects.LocalObjectEntry createLocalObjectEntry(RemoteReference<T> reference,
                                                                   T object)

This method must be overridden by the stage to create proper entries for Actors and Stateless Actors

Returns:

a object handle

stream

public Stream<Map.Entry<Object,LocalObjects.LocalObjectEntry>> stream()

getLocalObjectCount

public int getLocalObjectCount()

getLocalActorCount

public long getLocalActorCount()

remove

public void remove(Object key,
                   Object object)