diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 460cb9f1e4..8a18ee16df 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -2975,7 +2975,7 @@ public class DefaultMessageStore implements MessageStore { private DispatchService dispatchService; - public ConcurrentReputMessageService(){ + public ConcurrentReputMessageService() { super(); this.mainBatchDispatchRequestService = new MainBatchDispatchRequestService(); this.dispatchService = new DispatchService();