Skip to content

Commit b21df10

Browse files
committed
🐛 修改Message Client 示例项目支持新版本变动
1 parent 74afa34 commit b21df10

File tree

1 file changed

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

1 file changed

+2
-2
lines changed

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)