[GitHub] [rocketmq-spring] yibin001 opened a new issue #115: rocketMQTemplate.convertAndSend headers里的tag设置无效

[GitBox]

yibin001 opened a new issue #115: rocketMQTemplate.convertAndSend 
headers里的tag设置无效
URL: https://github.com/apache/rocketmq-spring/issues/115
 
 
   `
    rocketMQTemplate.convertAndSend("fst_pay_success", "message",new 
HashMap<String, Object>(){{
   
                   put(RocketMQHeaders.TAGS, "pay_success");  //指定tag
   
               }});
   
   `
   
   但实际这个tag指定是无效的，直接被 RocketMQUtil.convertToRocketMessage方法丢弃。
   代码里设置tag居然是加在topic后面：
   `String[] tempArr = destination.split(":", 2);
   
           String topic = tempArr[0];
   
           String tags = "";
   
           if (tempArr.length > 1) {
   
               tags = tempArr[1];
   
           }
   `
   
   是我用的不对？？

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services