Package org.apache.bookkeeper.proto

Class BookieProtoEncoding.ResponseEnDeCoderPreV3

java.lang.Object

org.apache.bookkeeper.proto.BookieProtoEncoding.ResponseEnDeCoderPreV3

All Implemented Interfaces:

BookieProtoEncoding.EnDecoder

Enclosing class:

BookieProtoEncoding

public static class BookieProtoEncoding.ResponseEnDeCoderPreV3
extends Object
implements BookieProtoEncoding.EnDecoder

A response encoder/decoder for the Bookkeeper protocol before version 3.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final com.google.protobuf.ExtensionRegistry	extensionRegistry

Constructor Summary

Constructors

Constructor	Description
ResponseEnDeCoderPreV3(com.google.protobuf.ExtensionRegistry extensionRegistry)

Method Summary

Modifier and Type	Method	Description
Object	decode(io.netty.buffer.ByteBuf buffer)	Decode a packet into an object.
Object	encode(Object msg, io.netty.buffer.ByteBufAllocator allocator)	Encode a object into channel buffer.
static void	serializeAddResponseInto(int rc, BookieProtocol.ParsedAddRequest req, io.netty.buffer.ByteBuf buf)

Methods inherited from class java.lang.Object

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

Field Details

extensionRegistry

final com.google.protobuf.ExtensionRegistry extensionRegistry

Constructor Details

ResponseEnDeCoderPreV3

public ResponseEnDeCoderPreV3(com.google.protobuf.ExtensionRegistry extensionRegistry)

Method Details

encode

public Object encode(Object msg,
 io.netty.buffer.ByteBufAllocator allocator)
              throws Exception

Description copied from interface: BookieProtoEncoding.EnDecoder

Encode a object into channel buffer.

Specified by:

encode in interface BookieProtoEncoding.EnDecoder

Parameters:

msg - object.

Returns:

encode buffer.

Throws:

Exception

decode

public Object decode(io.netty.buffer.ByteBuf buffer)
              throws Exception

Description copied from interface: BookieProtoEncoding.EnDecoder

Decode a packet into an object.

Specified by:

decode in interface BookieProtoEncoding.EnDecoder

Parameters:

buffer - received packet.

Returns:

parsed object.

Throws:

Exception

serializeAddResponseInto

public static void serializeAddResponseInto(int rc,
 BookieProtocol.ParsedAddRequest req,
 io.netty.buffer.ByteBuf buf)