diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java index 957dbbaaa32972c6b0e7af035737ee3dc314aeb3..8879a722fcf1967fd013aea6730c48bda6cf5c5c 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java @@ -584,7 +584,7 @@ public class PullMessageProcessor extends AsyncNettyRequestProcessor implements this.brokerController.getPullMessageExecutor().submit(new RequestTask(run, channel, request)); } - public void registerConsumeMessageHook(List sendMessageHookList) { - this.consumeMessageHookList = sendMessageHookList; + public void registerConsumeMessageHook(List consumeMessageHookList) { + this.consumeMessageHookList = consumeMessageHookList; } }