xiao-ma-nong opened a new issue #2540:
URL: https://github.com/apache/rocketmq/issues/2540
I used to send rocketmq transaction messages and reported the following
error(我使用发送rocketmq事务消息，
报以下错误)
````org.springframework.messaging.MessagingException: Can not found
MQProducer 'order_operate_history_group' in cache! please define
@RocketMQLocalTransactionListener class or invoke
createOrGetStartedTransactionMQProducer() to create it firstly````
/**
*
* Send transaction message(发送事务消息)
*
* @param topic
* @param tag
* @param body
* @throws Exception
*/
public void sendMessageInTransaction(String group, String topic, String
tag, String body) throws Exception {
log.info("【发送消息】：{}", body);
org.springframework.messaging.Message message =
MessageBuilder.withPayload(body).build();
TransactionSendResult result =
rocketMQTemplate.sendMessageInTransaction(group, topic, message, tag);
log.info("result->{}", result);
}
Has anyone encountered it? ? ?(有人遇到过吗？？？)
----------------------------------------------------------------
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:
[email protected]
