cloud.orbit.actors.runtime

Class Messaging

java.lang.Object

cloud.orbit.actors.net.HandlerAdapter

cloud.orbit.actors.runtime.Messaging

All Implemented Interfaces:

Handler, Startable

public class Messaging
extends HandlerAdapter
implements Startable

Handles matching requests with responses

Constructor Summary

Constructors

Constructor and Description
Messaging()

Method Summary

Modifier and Type	Method and Description
Task	cleanup()
Task	connect(HandlerContext ctx, Object param)
BasicRuntime	getRuntime()
protected void	onMessageReceived(HandlerContext ctx, Message message)
void	onRead(HandlerContext ctx, Object message)
protected void	sendResponseAndLogError(HandlerContext ctx, NodeAddress from, int messageId, int classId, int methodId, Object result, Throwable exception)
void	setResponseTimeoutMillis(long responseTimeoutMillis)
void	setRuntime(BasicRuntime runtime)
Task	write(HandlerContext ctx, Object msg)
Task<?>	writeInvocation(HandlerContext ctx, Invocation invocation)
Task<?>	writeMessage(HandlerContext ctx, Message message)

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

close, 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

Messaging

public Messaging()

Method Detail

setResponseTimeoutMillis

public void setResponseTimeoutMillis(long responseTimeoutMillis)

connect

public Task connect(HandlerContext ctx,
                    Object param)
             throws Exception

Specified by:

connect in interface Handler

Overrides:

connect in class HandlerAdapter

Throws:

Exception

onRead

public void onRead(HandlerContext ctx,
                   Object message)

Specified by:

onRead in interface Handler

Overrides:

onRead in class HandlerAdapter

onMessageReceived

protected void onMessageReceived(HandlerContext ctx,
                                 Message message)

sendResponseAndLogError

protected void sendResponseAndLogError(HandlerContext ctx,
                                       NodeAddress from,
                                       int messageId,
                                       int classId,
                                       int methodId,
                                       Object result,
                                       Throwable exception)

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)

writeMessage

public Task<?> writeMessage(HandlerContext ctx,
                            Message message)

cleanup

public Task cleanup()

getRuntime

public BasicRuntime getRuntime()

setRuntime

public void setRuntime(BasicRuntime runtime)