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

Validators.checkMessage() is used twice. (#3435)

Browse Source 
* fix(broker): can not clear topic unitSubFlag (#3429)

Co-authored-by: lushilin <lushilin.me@bytedance.com>

* Validators.checkMessage() is used twice.The other is used in sendDefaultImpl

Co-authored-by: lushilin <897401919@qq.com>
Co-authored-by: lushilin <lushilin.me@bytedance.com>
This commit is contained in:
BingCoke
2021-11-08 08:58:50 +08:00
committed by GitHub
co-authored by lushilin lushilin
parent c6aeb782e5
commit a51598dea5
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
-1
View File
@@ -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);
}