org.corfudb.runtime.clients

Class ClientMsgHandler

java.lang.Object

org.corfudb.runtime.clients.ClientMsgHandler

public class ClientMsgHandler
extends Object

Invokes the message handler to handle incoming messages.

Created by mwei on 7/27/16.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ClientMsgHandler.Handler<T extends CorfuMsg>

Constructor Summary

Constructors

Constructor and Description
ClientMsgHandler(IClient client) Construct a new instance of ClientMsgHandler.

Method Summary

Modifier and Type	Method and Description
<T extends CorfuMsg> ClientMsgHandler	addHandler(CorfuMsgType messageType, ClientMsgHandler.Handler<T> handler) Add a handler to this message handler.
ClientMsgHandler	generateHandlers(MethodHandles.Lookup caller, Object o) Generate handlers for a particular client.
Set<CorfuMsgType>	getHandledTypes() Get the types this handler will handle.
boolean	handle(CorfuMsg message, io.netty.channel.ChannelHandlerContext ctx) Handle an incoming CorfuMsg.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientMsgHandler

public ClientMsgHandler(IClient client)

Construct a new instance of ClientMsgHandler.

Method Detail

addHandler

public <T extends CorfuMsg> ClientMsgHandler addHandler(CorfuMsgType messageType,
                                                        ClientMsgHandler.Handler<T> handler)

Add a handler to this message handler.

Type Parameters:

T - A CorfuMsg type.

Parameters:

messageType - The type of CorfuMsg this handler will handle.

handler - The handler itself.

Returns:

This handler, to support chaining.

handle

public boolean handle(CorfuMsg message,
                      io.netty.channel.ChannelHandlerContext ctx)

Handle an incoming CorfuMsg.

Parameters:

message - The message to handle.

ctx - The channel handler context.

Returns:

True, if the message was handled. False otherwise.

generateHandlers

public ClientMsgHandler generateHandlers(@NonNull
                                         MethodHandles.Lookup caller,
                                         @NonNull
                                         Object o)

Generate handlers for a particular client.

Parameters:

caller - The context that is being used. Call MethodHandles.lookup() to obtain.

o - The object that implements the client.

Returns:

Returns a handler to handle incoming messages to clients.

getHandledTypes

public Set<CorfuMsgType> getHandledTypes()

Get the types this handler will handle.

Returns:

The types this handler will handle.