protected void decode()

in impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/handler/Decoder.java [41:52]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        if (!in.isReadable()) {
            return;
        }

        NettyRemotingBuffer wrapper = new NettyRemotingBuffer(in);

        Object msg = this.decode(ctx, wrapper);
        if (msg != null) {
            out.add(msg);
        }
    }