Package org.apache.bookkeeper.proto

Class BookieProtoEncoding.RequestEnDeCoderPreV3

java.lang.Object

org.apache.bookkeeper.proto.BookieProtoEncoding.RequestEnDeCoderPreV3

All Implemented Interfaces:

BookieProtoEncoding.EnDecoder

Enclosing class:

BookieProtoEncoding

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

An 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
RequestEnDeCoderPreV3(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

RequestEnDeCoderPreV3

public RequestEnDeCoderPreV3(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 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