cloud.orbit.actors.runtime

Class MessageLoopback

java.lang.Object

cloud.orbit.actors.extensions.NamedPipelineExtension

cloud.orbit.actors.runtime.MessageLoopback

All Implemented Interfaces:

ActorExtension, PipelineExtension, Handler, Startable

public class MessageLoopback
extends NamedPipelineExtension

Local messages traverse the protocol stack just beyond Messaging and then are bounced back. Their payload is cloned, this avoids full payload serialization.

Constructor Summary

Constructors

Constructor and Description
MessageLoopback()

Method Summary

Modifier and Type	Method and Description
ExecutionObjectCloner	getCloner()
ActorRuntime	getRuntime()
protected boolean	needsCloning(Message message)
void	setCloner(ExecutionObjectCloner cloner)
void	setRuntime(ActorRuntime runtime)
Task	write(HandlerContext ctx, Object msg)

Methods inherited from class cloud.orbit.actors.extensions.NamedPipelineExtension

getAfterHandlerName, getBeforeHandlerName, getName, setAfterHandlerName, setBeforeHandlerName, setName

Methods inherited from class java.lang.Object

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

Methods inherited from interface cloud.orbit.actors.extensions.PipelineExtension

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

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Constructor Detail

MessageLoopback

public MessageLoopback()

Method Detail

write

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

Throws:

Exception

needsCloning

protected boolean needsCloning(Message message)

getCloner

public ExecutionObjectCloner getCloner()

setCloner

public void setCloner(ExecutionObjectCloner cloner)

getRuntime

public ActorRuntime getRuntime()

setRuntime

public void setRuntime(ActorRuntime runtime)