fix: producer should format topic first (#81)

ali-sdk · May 10, 2019 · 456cd1f · 456cd1f
1 parent 38a9e9e
commit 456cd1f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/producer/mq_producer.js b/lib/producer/mq_producer.js
@@ -187,13 +187,13 @@ class MQProducer extends ClientConfig {
    */
   async send(msg) {
     await this.ready();
+    msg.topic = this.formatTopic(msg.topic);
 
     const topicPublishInfo = await this.tryToFindTopicPublishInfo(msg.topic);
     if (!topicPublishInfo) {
       throw new Error(`no publish router data for topic: ${msg.topic}`);
     }
 
-    msg.topic = this.formatTopic(msg.topic);
 
     const maxTimeout = this.options.sendMsgTimeout + 1000;
     const timesTotal = 1 + this.options.retryTimesWhenSendFailed;