cloud.orbit.actors.peer

Class PeerExecutor

java.lang.Object

cloud.orbit.actors.net.HandlerAdapter

cloud.orbit.actors.peer.PeerExecutor

All Implemented Interfaces:

Handler

public class PeerExecutor
extends HandlerAdapter

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger
protected LocalObjects	objects
protected BasicRuntime	runtime

Constructor Summary

Constructors

Constructor and Description
PeerExecutor()

Method Summary

Modifier and Type	Method and Description
protected void	onInvoke(HandlerContext ctx, Invocation invocation)
void	onRead(HandlerContext ctx, Object msg)
protected Task<Object>	performLocalInvocation(Invocation invocation, ObjectInvoker invoker, LocalObjects.LocalObjectEntry target)
Task	scheduleLocalInvocation(LocalObjects.LocalObjectEntry<Object> localObjectEntry, Invocation invocation)
void	setObjects(LocalObjects objects)
void	setRuntime(BasicRuntime runtime)
Task	write(HandlerContext ctx, Object msg)
Task	writeInvocation(HandlerContext ctx, Invocation invocation)

Methods inherited from class cloud.orbit.actors.net.HandlerAdapter

close, connect, disconnect, onActive, onEventTriggered, onExceptionCaught, onInactive, onRegistered

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected org.slf4j.Logger logger

objects

protected LocalObjects objects

runtime

protected BasicRuntime runtime

Constructor Detail

PeerExecutor

public PeerExecutor()

Method Detail

write

public Task write(HandlerContext ctx,
                  Object msg)
           throws Exception

Specified by:

write in interface Handler

Overrides:

write in class HandlerAdapter

Throws:

Exception

writeInvocation

public Task writeInvocation(HandlerContext ctx,
                            Invocation invocation)
                     throws Exception

Throws:

Exception

onRead

public void onRead(HandlerContext ctx,
                   Object msg)
            throws Exception

Specified by:

onRead in interface Handler

Overrides:

onRead in class HandlerAdapter

Throws:

Exception

onInvoke

protected void onInvoke(HandlerContext ctx,
                        Invocation invocation)

scheduleLocalInvocation

public Task scheduleLocalInvocation(LocalObjects.LocalObjectEntry<Object> localObjectEntry,
                                    Invocation invocation)

Returns:

the result of the method called

performLocalInvocation

protected Task<Object> performLocalInvocation(Invocation invocation,
                                              ObjectInvoker invoker,
                                              LocalObjects.LocalObjectEntry target)

setObjects

public void setObjects(LocalObjects objects)

setRuntime

public void setRuntime(BasicRuntime runtime)