Package org.apache.bookkeeper.proto

Class BookieProtoEncoding.RequestEnDecoderV3

java.lang.Object

org.apache.bookkeeper.proto.BookieProtoEncoding.RequestEnDecoderV3

All Implemented Interfaces:

BookieProtoEncoding.EnDecoder

Enclosing class:

BookieProtoEncoding

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

A request encoder/decoder for the Bookkeeper protocol version 3.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Object	decode(io.netty.buffer.ByteBuf packet)	Decode a packet into an object.
Object	encode(Object msg, io.netty.buffer.ByteBufAllocator allocator)	Encode a object into channel buffer.

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

RequestEnDecoderV3

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

Method Details

decode

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

Description copied from interface: BookieProtoEncoding.EnDecoder

Decode a packet into an object.

Specified by:

decode in interface BookieProtoEncoding.EnDecoder

Parameters:

packet - received packet.

Returns:

parsed object.

Throws:

Exception

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