From d460ce94b43e15e809663443249313a2c15e0eb3 Mon Sep 17 00:00:00 2001 From: Administrator <1069919773@qq.com> Date: Sun, 10 Oct 2021 19:50:36 +0800 Subject: [PATCH] trivial cleanups --- .../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 9d26e9982b9..3303d70e4ad 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 @@ protected SendMessageContext buildMsgContext(ChannelHandlerContext ctx, 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());