From a51598dea55fb88ee60ab0194d0ff06139d83aa2 Mon Sep 17 00:00:00 2001 From: BingCoke <81607010+BingCoke@users.noreply.github.com> Date: Mon, 8 Nov 2021 08:58:50 +0800 Subject: [PATCH] Validators.checkMessage() is used twice. (#3435) * fix(broker): can not clear topic unitSubFlag (#3429) Co-authored-by: lushilin * Validators.checkMessage() is used twice.The other is used in sendDefaultImpl Co-authored-by: lushilin <897401919@qq.com> Co-authored-by: lushilin --- .../org/apache/rocketmq/client/producer/DefaultMQProducer.java | 1 - 1 file changed, 1 deletion(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java b/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java index 1af416b48c..9f91b411e8 100644 --- a/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java +++ b/client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java @@ -331,7 +331,6 @@ public class DefaultMQProducer extends ClientConfig implements MQProducer { @Override public SendResult send( Message msg) throws MQClientException, RemotingException, MQBrokerException, InterruptedException { - Validators.checkMessage(msg, this); msg.setTopic(withNamespace(msg.getTopic())); return this.defaultMQProducerImpl.send(msg); }