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
FieldsModifier and TypeFieldDescription(package private) final com.google.protobuf.ExtensionRegistry -
Constructor Summary
ConstructorsConstructorDescriptionResponseEnDeCoderPreV3(com.google.protobuf.ExtensionRegistry extensionRegistry) -
Method Summary
Modifier and TypeMethodDescriptiondecode(io.netty.buffer.ByteBuf buffer) Decode a packet into an object.Encode a object into channel buffer.static voidserializeAddResponseInto(int rc, BookieProtocol.ParsedAddRequest req, io.netty.buffer.ByteBuf buf)
-
Field Details
-
extensionRegistry
final com.google.protobuf.ExtensionRegistry extensionRegistry
-
-
Constructor Details
-
ResponseEnDeCoderPreV3
public ResponseEnDeCoderPreV3(com.google.protobuf.ExtensionRegistry extensionRegistry)
-
-
Method Details
-
encode
Description copied from interface:BookieProtoEncoding.EnDecoderEncode a object into channel buffer.- Specified by:
encodein interfaceBookieProtoEncoding.EnDecoder- Parameters:
msg- object.- Returns:
- encode buffer.
- Throws:
Exception
-
decode
Description copied from interface:BookieProtoEncoding.EnDecoderDecode a packet into an object.- Specified by:
decodein interfaceBookieProtoEncoding.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)
-