Merge pull request #61 from hengboy/2.3.x

⬆️ 升级使用Message Pipe版本为v1.0.1

Author: hengboy

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>

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;
     }
 }