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<MessageExt> msgList, String brokerNam
             }
         };
 
-        if (messageStore != null) {
-            messageStore.setSendMessageBackHook(sendMessageBackHook);
-        }
+        messageStore.setSendMessageBackHook(sendMessageBackHook);
+
     }
 
     private void initialTransaction() {