cloud.orbit.actors.peer

Class Peer

java.lang.Object

cloud.orbit.actors.peer.Peer

All Implemented Interfaces:

BasicRuntime, DescriptorFactory, Startable

Direct Known Subclasses:

ClientPeer, ServerPeer

public abstract class Peer
extends Object
implements Startable, BasicRuntime

This works as a bridge to perform calls between the server and a client.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	localIdentity
protected LocalObjects	objects

Constructor Summary

Constructors

Constructor and Description
Peer()

Method Summary

Modifier and Type	Method and Description
void	addExtension(PeerExtension extension)
void	bind()
Clock	clock()
List<PeerExtension>	getExtensions()
protected <T> T	getFirstExtension(Class<T> itemType)
MessageSerializer	getMessageSerializer()
Handler	getNetwork()
Pipeline	getPipeline()
<T> T	getReference(BasicRuntime runtime, NodeAddress address, Class<T> iClass, Object id)
<T> AsyncStream<T>	getStream(String provider, Class<T> dataClass, String id)
protected void	installPipelineExtensions()
Task<?>	invoke(RemoteReference toReference, Method m, boolean oneWay, int methodId, Object[] params)
<T extends ActorObserver> T	registerObserver(Class<T> iClass, String id, T observer)
void	setClock(Clock clock)
void	setMessageSerializer(MessageSerializer messageSerializer)
void	setNetworkHandler(Handler network)

Methods inherited from class java.lang.Object

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

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Methods inherited from interface cloud.orbit.actors.runtime.BasicRuntime

getLogger, getReference, getRemoteObserverReference, getRuntime, getStream, registerObserver, setRuntime

Methods inherited from interface cloud.orbit.actors.runtime.DescriptorFactory

getInvoker, getInvoker, getReference

Field Detail

objects

protected LocalObjects objects

localIdentity

protected final String localIdentity

Constructor Detail

Peer

public Peer()

Method Detail

setNetworkHandler

public void setNetworkHandler(Handler network)

getNetwork

public Handler getNetwork()

setMessageSerializer

public void setMessageSerializer(MessageSerializer messageSerializer)

clock

public Clock clock()

Specified by:

clock in interface BasicRuntime

getMessageSerializer

public MessageSerializer getMessageSerializer()

setClock

public void setClock(Clock clock)

getPipeline

public Pipeline getPipeline()

invoke

public Task<?> invoke(RemoteReference toReference,
                      Method m,
                      boolean oneWay,
                      int methodId,
                      Object[] params)

Specified by:

invoke in interface BasicRuntime

registerObserver

public <T extends ActorObserver> T registerObserver(Class<T> iClass,
                                                    String id,
                                                    T observer)

Specified by:

registerObserver in interface BasicRuntime

getStream

public <T> AsyncStream<T> getStream(String provider,
                                    Class<T> dataClass,
                                    String id)

Specified by:

getStream in interface BasicRuntime

installPipelineExtensions

protected void installPipelineExtensions()

getReference

public <T> T getReference(BasicRuntime runtime,
                          NodeAddress address,
                          Class<T> iClass,
                          Object id)

Specified by:

getReference in interface DescriptorFactory

getExtensions

public List<PeerExtension> getExtensions()

getFirstExtension

protected <T> T getFirstExtension(Class<T> itemType)

addExtension

public void addExtension(PeerExtension extension)

bind

public void bind()

Specified by:

bind in interface BasicRuntime