diff --git a/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java b/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
index 9c186ad33..941bdebee 100644
--- a/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
+++ b/src/main/java/com/genersoft/iot/vmp/common/StreamInfo.java
@@ -182,7 +182,8 @@ public class StreamInfo implements Serializable, Cloneable{
         if (callIdParam != null) {
             callIdParam = Objects.equals(callIdParam, "") ? callIdParam : callIdParam.replace("?", "&");
         }
-        String file = String.format("%s/%s?type=%s%s", app, stream, isPlay?"play":"push", callIdParam);
+//        String file = String.format("%s/%s?type=%s%s", app, stream, isPlay?"play":"push", callIdParam);
+        String file = String.format("index/api/webrtc?app=%s&stream=%s&type=%s%s", app, stream, isPlay?"play":"push", callIdParam);
         if (port > 0) {
             this.rtc = new StreamURL("http", host, port, file);
         }
diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java b/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java
index cf03aaa41..1c5f6108e 100644
--- a/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/codec/decode/Jt808Decoder.java
@@ -88,6 +88,7 @@ public class Jt808Decoder extends ByteToMessageDecoder {
             if (decode != null) {
                 out.add(decode);
             }
+            buf.release();
         } finally {
             in.skipBytes(in.readableBytes());
         }
diff --git a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java
index 03a66f497..1609caa64 100644
--- a/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java
+++ b/src/main/java/com/genersoft/iot/vmp/jt1078/proc/request/Re.java
@@ -28,7 +28,6 @@ public abstract class Re {
             session.register(header.getPhoneNumber(), (int) header.getVersion(), header);
         }
         Rs rs = decode0(buf, header, session);
-        buf.release();
         Rs rsHand = handler(header, session, service);
         if (rs == null && rsHand != null) {
             rs = rsHand;