From 9a03f603039aea413f0cef32e5c952290149d8cf Mon Sep 17 00:00:00 2001
From: smallchi <564952747@qq.com>
Date: Fri, 11 Oct 2019 11:10:35 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=B6=88=E6=81=AF=E5=BA=94?=
 =?UTF-8?q?=E7=AD=94=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Impls/JT808MsgReplyConsumerDefaultImpl.cs                 | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/JT808.DotNetty.Core/Impls/JT808MsgReplyConsumerDefaultImpl.cs b/src/JT808.DotNetty.Core/Impls/JT808MsgReplyConsumerDefaultImpl.cs
index 6b97be3..21b1928 100644
--- a/src/JT808.DotNetty.Core/Impls/JT808MsgReplyConsumerDefaultImpl.cs
+++ b/src/JT808.DotNetty.Core/Impls/JT808MsgReplyConsumerDefaultImpl.cs
@@ -47,7 +47,7 @@ namespace JT808.DotNetty.Core.Impls
         {
             Task.Run(() =>
             {
-                foreach(var item in JT808MsgService.MsgQueue.GetConsumingEnumerable(Cts.Token))
+                foreach(var item in JT808MsgService.MsgQueue.GetConsumingEnumerable())
                 {
                     try
                     {
@@ -57,7 +57,7 @@ namespace JT808.DotNetty.Core.Impls
                             var buffer = func(package);
                             if (buffer != null)
                             {
-                                callback((item.TerminalNo, item.Data));
+                                callback((item.TerminalNo, buffer));
                             }
                         }
                     }