From 99cea325562a62d2842ee6df62c8aac9355d7468 Mon Sep 17 00:00:00 2001
From: tzssangglass <tzssangglass@gmail.com>
Date: Wed, 2 Jun 2021 21:31:25 +0800
Subject: [PATCH] feat: use netty's own unpacking decoder (#26)

---
 .../plugin/runner/codec/DelayedDecoder.java     | 17 +----------------
 1 file changed, 1 insertion(+), 16 deletions(-)

diff --git a/runner-core/src/main/java/org/apache/apisix/plugin/runner/codec/DelayedDecoder.java b/runner-core/src/main/java/org/apache/apisix/plugin/runner/codec/DelayedDecoder.java
index c950390..df883fa 100644
--- a/runner-core/src/main/java/org/apache/apisix/plugin/runner/codec/DelayedDecoder.java
+++ b/runner-core/src/main/java/org/apache/apisix/plugin/runner/codec/DelayedDecoder.java
@@ -17,26 +17,11 @@
 
 package org.apache.apisix.plugin.runner.codec;
 
-import io.netty.buffer.ByteBuf;
-import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.LengthFieldBasedFrameDecoder;
 
 public class DelayedDecoder extends LengthFieldBasedFrameDecoder {
 
     public DelayedDecoder() {
-        super(16777215, 0, 0);
-    }
-
-    @Override
-    protected ByteBuf decode(ChannelHandlerContext ctx, ByteBuf in) {
-        in.readByte();
-        int length = in.readMedium();
-        if (in.readableBytes() < length) {
-            return null;
-        }
-        in.readerIndex(0);
-
-        int readLength = in.readableBytes();
-        return in.retainedSlice(0, readLength);
+        super(16777215, 1, 3, 0, 0);
     }
 }
\ No newline at end of file