From 6b8a2b2fce91d6486b477adb2cb762a3e119c9f4 Mon Sep 17 00:00:00 2001 From: alitor <1069919773@qq.com> Date: Tue, 26 Oct 2021 13:44:23 +0800 Subject: [PATCH] trivial cleanups (#3403) --- .../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 9d26e9982b..3303d70e4a 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());