rainbowrain2023 opened a new issue, #571:
URL: https://github.com/apache/rocketmq-spring/issues/571
> String[] tempArr = destination.split(":", 2);
> String topic = tempArr[0];
> String tags = "";
> if (tempArr.length > 1) {
> tags = tempArr[1];
> }
> Message rocketMsg = new Message(topic, tags, payloads);
上述代码体现你构建RocketMq的Message时的参数,由于topic和tags融合成一个String类型的destination字段,所以在需要设置tags发送时需要进行destination字段的装箱操作,这很不利于api的便捷调用
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]