From a6c2e3e9d84f6a47f0738f1cdd7c6e29d206c2b6 Mon Sep 17 00:00:00 2001 From: yx9o Date: Wed, 4 Feb 2026 22:11:05 +0800 Subject: [PATCH] [ISSUE #10068] Remove duplicate registration in DefaultMessagingProcessor.init --- .../rocketmq/proxy/processor/DefaultMessagingProcessor.java | 1 - 1 file changed, 1 deletion(-) diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java b/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java index 60c9261050d..274cbf37daf 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java @@ -142,7 +142,6 @@ protected void init() { this.appendStartAndShutdown(this.receiptHandleProcessor); this.appendShutdown(this.producerProcessorExecutor::shutdown); this.appendShutdown(this.consumerProcessorExecutor::shutdown); - this.appendStartAndShutdown(this.receiptHandleProcessor); } @Override