From 74afa34e905c7f724c81f02da19abcbd061f51cb Mon Sep 17 00:00:00 2001
From: hengboy <jnyuqy@gmail.com>
Date: Mon, 31 Aug 2020 09:20:44 +0800
Subject: [PATCH 1/2] =?UTF-8?q?:arrow=5Fup:=20=E5=8D=87=E7=BA=A7=E4=BD=BF?=
 =?UTF-8?q?=E7=94=A8Message=20Pipe=E7=89=88=E6=9C=AC=E4=B8=BAv1.0.1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 api-boot-project/api-boot-dependencies/pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/api-boot-project/api-boot-dependencies/pom.xml b/api-boot-project/api-boot-dependencies/pom.xml
index 91a214ac..cda39ec0 100644
--- a/api-boot-project/api-boot-dependencies/pom.xml
+++ b/api-boot-project/api-boot-dependencies/pom.xml
@@ -22,7 +22,7 @@
         <!--Minbox Projects-->
         <minbox-bom.version>1.0.1.RELEASE</minbox-bom.version>
         <code.builder.core.version>1.0.5.RELEASE</code.builder.core.version>
-        <message-pipe.version>1.0.0.RELEASE</message-pipe.version>
+        <message-pipe.version>1.0.1.RELEASE</message-pipe.version>
 
         <!--Others-->
         <druid.starter.version>1.1.21</druid.starter.version>

From b21df10da3e77918801dcca9f3921c4432226c8a Mon Sep 17 00:00:00 2001
From: hengboy <jnyuqy@gmail.com>
Date: Mon, 31 Aug 2020 09:27:53 +0800
Subject: [PATCH 2/2] =?UTF-8?q?:bug:=20=E4=BF=AE=E6=94=B9Message=20Client?=
 =?UTF-8?q?=20=E7=A4=BA=E4=BE=8B=E9=A1=B9=E7=9B=AE=E6=94=AF=E6=8C=81?=
 =?UTF-8?q?=E6=96=B0=E7=89=88=E6=9C=AC=E5=8F=98=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../message/pipe/client/processor/TestMessageProcessor.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor/TestMessageProcessor.java b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor/TestMessageProcessor.java
index 4cd7f6e0..4b0f75db 100644
--- a/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor/TestMessageProcessor.java
+++ b/api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor/TestMessageProcessor.java
@@ -20,8 +20,8 @@ public String bindingPipeName() {
     }
 
     @Override
-    public boolean processing(String requestId, byte[] messageBody) {
-        log.info("消费消息：{}，内容：{}", requestId, new String(messageBody));
+    public boolean processing(String specificPipeName, String requestId, byte[] messageBody) {
+        log.info("具体管道：{}，消费消息：{}，内容：{}", specificPipeName, requestId, new String(messageBody));
         return true;
     }
 }