opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 13:49:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

trivial cleanups (#3403)

Browse Source
This commit is contained in:
alitor
2021-10-26 13:44:23 +08:00
committed by GitHub
parent 21faa68b4c
commit 6b8a2b2fce
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
+1 -2
View File
@@ -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());