All Implemented Interfaces:

ChannelHandler, ChannelInboundHandler

@ChannelHandler.Sharable
public class ProtobufDecoder
extends MessageToMessageDecoder<ByteBuf>

 ChannelPipeline pipeline = ...;
 // Decoders
 pipeline.addLast("frameDecoder",
 new LengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4));
 pipeline.addLast("protobufDecoder",
 new ProtobufDecoder(MyMessage.getDefaultInstance()));
 // Encoder
 pipeline.addLast("frameEncoder", new LengthFieldPrepender(4));
 pipeline.addLast("protobufEncoder", new ProtobufEncoder());
 

 void channelRead(ChannelHandlerContext ctx, MyMessage req) {
 MyMessage res = MyMessage.newBuilder().setText(
 "Did you say '" + req.getText() + "'?").build();
 ch.write(res);
 }
 

• Nested Class Summary

  • Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

    ChannelHandler.Sharable

• Constructor Summary

  Constructors

  Constructor and Description
  ProtobufDecoder (MessageLite prototype) Creates a new instance.
  ProtobufDecoder (MessageLite prototype, ExtensionRegistry extensionRegistry)
  ProtobufDecoder (MessageLite prototype, ExtensionRegistryLite extensionRegistry)

• Method Summary

  All Methods

  Modifier and Type	Method and Description
  protected void	decode (ChannelHandlerContext ctx, ByteBuf msg, java.util.List<java.lang.Object> out) Decode from one message to an other.

  • Methods inherited from class io.netty.handler.codec.MessageToMessageDecoder

    acceptInboundMessage, channelRead

  • Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

    channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

  • Methods inherited from class io.netty.channel.ChannelHandlerAdapter

    ensureNotSharable, handlerAdded, handlerRemoved, isSharable

  • Methods inherited from class java.lang.Object

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

  • Methods inherited from interface io.netty.channel.ChannelHandler

    handlerAdded, handlerRemoved

• Constructor Detail

  • ProtobufDecoder

    public ProtobufDecoder(MessageLite prototype)

    Creates a new instance.

  • ProtobufDecoder

    public ProtobufDecoder(MessageLite prototype,
     ExtensionRegistry extensionRegistry)

  • ProtobufDecoder

    public ProtobufDecoder(MessageLite prototype,
     ExtensionRegistryLite extensionRegistry)

• Method Detail

  • decode

    protected void decode(ChannelHandlerContext ctx,
     ByteBuf msg,
     java.util.List<java.lang.Object> out)
     throws java.lang.Exception

    Description copied from class: MessageToMessageDecoder
    Decode from one message to an other. This method will be called for each written message that can be handled by this encoder.

    Specified by:

    decode in class MessageToMessageDecoder<ByteBuf>

    Parameters:

    ctx - the ChannelHandlerContext which this MessageToMessageDecoder belongs to

    msg - the message to decode to an other one

    out - the List to which decoded messages should be added

    Throws:

    java.lang.Exception - is thrown if an error occurs