cloud.orbit.actors.runtime

Class Execution

java.lang.Object

cloud.orbit.actors.net.HandlerAdapter

cloud.orbit.actors.runtime.AbstractExecution

cloud.orbit.actors.runtime.Execution

All Implemented Interfaces:

Handler, Startable

public class Execution
extends AbstractExecution
implements Startable

Field Summary

Fields inherited from class cloud.orbit.actors.runtime.AbstractExecution

executionSerializer, logger, maxQueueSize, messagesHandled, messagesReceived, refusedExecutions

Constructor Summary

Constructors

Constructor and Description
Execution()

Method Summary

Modifier and Type	Method and Description
Task<Void>	cleanup()
protected void	onInvocation(HandlerContext ctx, Invocation invocation)
void	onRead(HandlerContext ctx, Object msg)
protected Task<Object>	performInvocation(HandlerContext ctx, Invocation invocation, LocalObjects.LocalObjectEntry entry, LocalObjects.LocalObjectEntry target)
void	setInvocationHandler(InvocationHandler invocationHandler)
void	setObjects(LocalObjects objects)
void	setRuntime(Stage runtime)
Task	write(HandlerContext ctx, Object msg)

Methods inherited from class cloud.orbit.actors.runtime.AbstractExecution

setExecutionSerializer

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

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Constructor Detail

Execution

public Execution()

Method Detail

cleanup

public Task<Void> cleanup()

Specified by:

cleanup in class AbstractExecution

setRuntime

public void setRuntime(Stage runtime)

write

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

Specified by:

write in interface Handler

Overrides:

write in class HandlerAdapter

Throws:

Exception

onRead

public void onRead(HandlerContext ctx,
                   Object msg)

Specified by:

onRead in interface Handler

Overrides:

onRead in class HandlerAdapter

onInvocation

protected void onInvocation(HandlerContext ctx,
                            Invocation invocation)

performInvocation

protected Task<Object> performInvocation(HandlerContext ctx,
                                         Invocation invocation,
                                         LocalObjects.LocalObjectEntry entry,
                                         LocalObjects.LocalObjectEntry target)

setInvocationHandler

public void setInvocationHandler(InvocationHandler invocationHandler)

setObjects

public void setObjects(LocalObjects objects)