opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #6119] replace ScheduleMessageService method reference

Browse Source
This commit is contained in:
hardyfish
2023-02-28 08:15:44 +08:00
committed by GitHub
parent 7a454477c5
commit 8667a0d335
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
+1 -3
View File
@@ -717,9 +717,7 @@ public class ScheduleMessageService extends ConfigManager {
}
public PutResultProcess thenProcess() {
this.future.thenAccept(result -> {
this.handleResult(result);
});
this.future.thenAccept(this::handleResult);
this.future.exceptionally(e -> {
log.error("ScheduleMessageService put message exceptionally, info: {}",