org.corfudb.protocols.wireprotocol

Class JSONPayloadMsg<T>

java.lang.Object

org.corfudb.protocols.wireprotocol.CorfuMsg

org.corfudb.protocols.wireprotocol.JSONPayloadMsg<T>

public class JSONPayloadMsg<T>
extends CorfuMsg

Created by mwei on 7/27/16.

Constructor Summary

Constructors

Constructor and Description
JSONPayloadMsg(T payload, CorfuMsgType type)

Method Summary

Modifier and Type	Method and Description
void	fromBuffer(io.netty.buffer.ByteBuf buffer) Parse the rest of the message from the buffer.
T	getPayload() Get the payload.
void	serialize(io.netty.buffer.ByteBuf buffer) Serialize the message into the given bytebuffer.

Methods inherited from class org.corfudb.protocols.wireprotocol.CorfuMsg

copyBaseFields, deserialize, release

Methods inherited from class java.lang.Object

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

Constructor Detail

JSONPayloadMsg

public JSONPayloadMsg(T payload,
                      CorfuMsgType type)

Method Detail

serialize

public void serialize(io.netty.buffer.ByteBuf buffer)

Serialize the message into the given bytebuffer.

Overrides:

serialize in class CorfuMsg

Parameters:

buffer - The buffer to serialize to.

fromBuffer

public void fromBuffer(io.netty.buffer.ByteBuf buffer)

Parse the rest of the message from the buffer. Classes that extend CorfuMsg should parse their fields in this method.

Overrides:

fromBuffer in class CorfuMsg

Parameters:

buffer - to parse message from

getPayload

public T getPayload()

Get the payload. Uses some type reflection voodoo in order to get the type to the JSON parser, so make sure to correctly parameterize this class, using with a raw type will most definitely fail.

Returns:

The JSON payload.