org.corfudb.protocols.wireprotocol

Class CorfuPayloadMsg<T>

java.lang.Object

org.corfudb.protocols.wireprotocol.CorfuMsg

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

public class CorfuPayloadMsg<T>
extends CorfuMsg

A message type which represents an encapsulated Corfu payload.

T should be either of a primitive boxed type (Long, Integer, etc) or of ICorfuPayload.

NEVER, EVER use this class as a raw type. This class DEPENDS on the generic captured at runtime by CorfuMsg (via TypeToken).

Created by mwei on 8/1/16.

Constructor Summary

Constructors

Constructor and Description
CorfuPayloadMsg(CorfuMsgType msgType, T payload)

Method Summary

Modifier and Type	Method and Description
void	fromBuffer(io.netty.buffer.ByteBuf buffer) Parse the rest of the message from the buffer.
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

CorfuPayloadMsg

public CorfuPayloadMsg(CorfuMsgType msgType,
                       T payload)

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 - contains the message from the buffer