[rocketmq] branch develop updated: Validators.checkMessage() is used twice. (#3435)

[du...@apache.org]

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 a51598d  Validators.checkMessage() is used twice. (#3435)
a51598d is described below

commit a51598dea55fb88ee60ab0194d0ff06139d83aa2
Author: BingCoke <81...@users.noreply.github.com>
AuthorDate: Mon Nov 8 08:58:50 2021 +0800

    Validators.checkMessage() is used twice. (#3435)
    
    * fix(broker): can not clear topic unitSubFlag (#3429)
    
    Co-authored-by: lushilin <lu...@bytedance.com>
    
    * Validators.checkMessage() is used twice.The other is used in sendDefaultImpl
    
    Co-authored-by: lushilin <89...@qq.com>
    Co-authored-by: lushilin <lu...@bytedance.com>
---
 .../main/java/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 1af416b..9f91b41 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);
     }