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 java.lang.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) com.google.protobuf.ExtensionRegistry	extensionRegistry

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
java.lang.Object	decode(io.netty.buffer.ByteBuf buffer)	Decode a packet into an object.
java.lang.Object	encode(java.lang.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 Detail

extensionRegistry

final com.google.protobuf.ExtensionRegistry extensionRegistry

Constructor Detail

ResponseEnDeCoderPreV3

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

Method Detail

encode

public java.lang.Object encode(java.lang.Object msg,
                               io.netty.buffer.ByteBufAllocator allocator)
                        throws java.lang.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:

java.lang.Exception

decode

public java.lang.Object decode(io.netty.buffer.ByteBuf buffer)
                        throws java.lang.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:

java.lang.Exception

serializeAddResponseInto

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