You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/10/26 05:44:29 UTC
[rocketmq] branch develop updated: trivial cleanups (#3403)
This is an automated email from the ASF dual-hosted git repository.
duhengforever 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 6b8a2b2 trivial cleanups (#3403)
6b8a2b2 is described below
commit 6b8a2b2fce91d6486b477adb2cb762a3e119c9f4
Author: alitor <10...@qq.com>
AuthorDate: Tue Oct 26 13:44:23 2021 +0800
trivial cleanups (#3403)
---
.../apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java | 3 +--
1 file changed, 1 insertion(+), 2 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 9d26e99..3303d70 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
@@ -77,8 +77,7 @@ public abstract class AbstractSendMessageProcessor extends AsyncNettyRequestProc
return null;
}
String namespace = NamespaceUtil.getNamespaceFromResource(requestHeader.getTopic());
- SendMessageContext mqtraceContext;
- mqtraceContext = new SendMessageContext();
+ SendMessageContext mqtraceContext = new SendMessageContext();
mqtraceContext.setProducerGroup(requestHeader.getProducerGroup());
mqtraceContext.setNamespace(namespace);
mqtraceContext.setTopic(requestHeader.getTopic());