You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2023/01/11 11:49:09 UTC
[rocketmq] branch develop updated: [ISSUE #5869] Remove unnecessary verification logic in consumerSendMsgBack method (#5868)
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 7694a69d5 [ISSUE #5869] Remove unnecessary verification logic in consumerSendMsgBack method (#5868)
7694a69d5 is described below
commit 7694a69d599c7b406a26fc35560e3ad01a6755a7
Author: rongtong <ji...@163.com>
AuthorDate: Wed Jan 11 19:49:01 2023 +0800
[ISSUE #5869] Remove unnecessary verification logic in consumerSendMsgBack method (#5868)
---
.../rocketmq/broker/processor/AbstractSendMessageProcessor.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
index 933a8984b..b348ecb8f 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
@@ -161,15 +161,6 @@ public abstract class AbstractSendMessageProcessor implements NettyRequestProces
return response;
}
- //for logic queue
- if (requestHeader.getOriginTopic() != null
- && !msgExt.getTopic().equals(requestHeader.getOriginTopic())) {
- //here just do some fence in case of some unexpected offset is income
- response.setCode(ResponseCode.SYSTEM_ERROR);
- response.setRemark("look message by offset failed to check the topic name" + requestHeader.getOffset());
- return response;
- }
-
final String retryTopic = msgExt.getProperty(MessageConst.PROPERTY_RETRY_TOPIC);
if (null == retryTopic) {
MessageAccessor.putProperty(msgExt, MessageConst.PROPERTY_RETRY_TOPIC, msgExt.getTopic());