From 8062dae55437ed1e2a16b66a6ad92be062a0138c Mon Sep 17 00:00:00 2001 From: mxsm Date: Sat, 6 Sep 2025 00:13:43 +0800 Subject: [PATCH] [ISSUE #9670]Simplify messageStore sendMessageBackHook assignment by removing null check --- .../java/org/apache/rocketmq/broker/BrokerController.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java index 595737adf71..90e392be0f0 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java @@ -1016,9 +1016,8 @@ public boolean executeSendMessageBack(List msgList, String brokerNam } }; - if (messageStore != null) { - messageStore.setSendMessageBackHook(sendMessageBackHook); - } + messageStore.setSendMessageBackHook(sendMessageBackHook); + } private void initialTransaction() {