From 8667a0d335ebcbde78d2aaf47209221d5eccf9e8 Mon Sep 17 00:00:00 2001
From: hardyfish <85128645+hardyfish@users.noreply.github.com>
Date: Tue, 28 Feb 2023 08:15:44 +0800
Subject: [PATCH] [ISSUE #6119] replace ScheduleMessageService method reference

---
 .../rocketmq/broker/schedule/ScheduleMessageService.java      | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
index 26e757ab41..bdc9c56725 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
@@ -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: {}",