[rocketmq] 01/01: Add null point check before send message with namespace

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git

commit 08b62fca024cc9bfa496c3c925bbf8d877919293
Author: ShannonDing <libya_...@163.com>
AuthorDate: Tue May 14 20:59:19 2019 +0800

    Add null point check before send message with namespace
---
 .../main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java | 1 +
 1 file changed, 1 insertion(+)

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 3a26e83..d5fbde0 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,6 +331,7 @@ 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);
     }