cloud.orbit.actors.runtime

Class ClusterHandler

java.lang.Object

cloud.orbit.actors.net.HandlerAdapter

cloud.orbit.actors.runtime.ClusterHandler

All Implemented Interfaces:

Handler

public class ClusterHandler
extends HandlerAdapter

Constructor Summary

Constructors

Constructor and Description
ClusterHandler(ClusterPeer clusterPeer, String clusterName, String nodeName)

Method Summary

Modifier and Type	Method and Description
Task	close(HandlerContext ctx)
Task	connect(HandlerContext ctx, Object param)
Task	write(HandlerContext ctx, Object msg)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterHandler

public ClusterHandler(ClusterPeer clusterPeer,
                      String clusterName,
                      String nodeName)

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

connect

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

Specified by:

connect in interface Handler

Overrides:

connect in class HandlerAdapter

Throws:

Exception

close

public Task close(HandlerContext ctx)
           throws Exception

Specified by:

close in interface Handler

Overrides:

close in class HandlerAdapter

Throws:

Exception