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 @@ 1.0.1.RELEASE 1.0.5.RELEASE - 1.0.0.RELEASE + 1.0.1.RELEASE 1.1.21 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; } }