private org.apache.rocketmq.common.message.Message createRocketMqMessage(
        String destination, Message<?> message) {
        Message<?> msg = this.doConvert(message.getPayload(), message.getHeaders(), null);
        return RocketMQUtil.convertToRocketMessage(getMessageConverter(), charset,
            destination, msg);
    }
Send Spring Message in Transaction

@param destination destination formats: `topicName:tags`
@param message message {@link org.springframework.messaging.Message}
@param arg ext arg
@return TransactionSendResult
@throws MessagingException
rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java