This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new c2c674dcd4 [ISSUE #10068] Remove duplicate registration in 
DefaultMessagingProcessor.init (#10069)
c2c674dcd4 is described below

commit c2c674dcd4ab28e933ee6b383e2ff92096a77e3c
Author: yx9o <[email protected]>
AuthorDate: Thu Feb 5 13:57:09 2026 +0800

    [ISSUE #10068] Remove duplicate registration in 
DefaultMessagingProcessor.init (#10069)
---
 .../org/apache/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 60c9261050..274cbf37da 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 @@ public class DefaultMessagingProcessor extends 
AbstractStartAndShutdown implemen
         this.appendStartAndShutdown(this.receiptHandleProcessor);
         this.appendShutdown(this.producerProcessorExecutor::shutdown);
         this.appendShutdown(this.consumerProcessorExecutor::shutdown);
-        this.appendStartAndShutdown(this.receiptHandleProcessor);
     }
 
     @Override

Reply via email to