Skip to content

Commit 13b2f59

Browse files
committed
Merge remote-tracking branch 'origin/2.3.x' into 2.3.x
2 parents 2e309cc + f3ddfd6 commit 13b2f59

File tree

2 files changed

+3
-3
lines changed
  • api-boot-project/api-boot-dependencies
  • api-boot-samples/api-boot-sample-message-pipe-client/src/main/java/org/minbox/framework/api/boot/sample/message/pipe/client/processor

2 files changed

+3
-3
lines changed

api-boot-project/api-boot-dependencies/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
<!--Minbox Projects-->
2323
<minbox-bom.version>1.0.1.RELEASE</minbox-bom.version>
2424
<code.builder.core.version>1.0.5.RELEASE</code.builder.core.version>
25-
<message-pipe.version>1.0.0.RELEASE</message-pipe.version>
25+
<message-pipe.version>1.0.1.RELEASE</message-pipe.version>
2626

2727
<!--Others-->
2828
<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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@ public String bindingPipeName() {
2020
}
2121

2222
@Override
23-
public boolean processing(String requestId, byte[] messageBody) {
24-
log.info("消费消息:{},内容:{}", requestId, new String(messageBody));
23+
public boolean processing(String specificPipeName, String requestId, byte[] messageBody) {
24+
log.info("具体管道:{},消费消息:{},内容:{}", specificPipeName, requestId, new String(messageBody));
2525
return true;
2626
}
2727
}

0 commit comments

Comments
 (0)