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