[ISSUE #10068] Remove duplicate registration in DefaultMessagingProcessor.init (#10069)

yx9o · web-flow · commit c2c674dcd4ab · 2026-02-05T13:57:09.000+08:00
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
@@ -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

Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,6 @@ protected void init() {`
`142`	`142`	`this.appendStartAndShutdown(this.receiptHandleProcessor);`
`143`	`143`	`this.appendShutdown(this.producerProcessorExecutor::shutdown);`
`144`	`144`	`this.appendShutdown(this.consumerProcessorExecutor::shutdown);`
`145`		`- this.appendStartAndShutdown(this.receiptHandleProcessor);`
`146`	`145`	`}`
`147`	`146`
`148`	`147`	`@Override`