cloud.orbit.actors.extensions

Class LengthFieldHandler

java.lang.Object

cloud.orbit.actors.extensions.NamedPipelineExtension

cloud.orbit.actors.extensions.LengthFieldHandler

All Implemented Interfaces:

ActorExtension, PipelineExtension, Handler, PeerExtension, Startable

public class LengthFieldHandler
extends NamedPipelineExtension
implements Handler, PipelineExtension, PeerExtension

Prepends each message with a 4 byte big endian length field. The the length indicates the data length.

Example:

     | length      | payload        |
     | 00 00 00 05 | 6f 72 62 69 74 | ____orbit
 

Field Summary

Fields

Modifier and Type	Field and Description
static String	LENGTH_FIELD_ENCODING

Constructor Summary

Constructors

Constructor and Description
LengthFieldHandler()
LengthFieldHandler(String name, String beforeHandlerName, String afterHandlerName)

Method Summary

Modifier and Type	Method and Description
void	onRead(HandlerContext ctx, Object msg)
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, getAfterHandlerName, getBeforeHandlerName, getName, onActive, onEventTriggered, onExceptionCaught, onInactive, onRegistered

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Field Detail

LENGTH_FIELD_ENCODING

public static final String LENGTH_FIELD_ENCODING

See Also:

Constant Field Values

Constructor Detail

LengthFieldHandler

public LengthFieldHandler()

LengthFieldHandler

public LengthFieldHandler(String name,
                          String beforeHandlerName,
                          String afterHandlerName)

Method Detail

write

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

Specified by:

write in interface PipelineExtension

Specified by:

write in interface Handler

Throws:

Exception

onRead

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

Specified by:

onRead in interface PipelineExtension

Specified by:

onRead in interface Handler

Throws:

Exception