Dreamroute opened a new issue #58: 事务消息返回值问题 URL: https://github.com/apache/rocketmq-spring/issues/58 @Override public DemoCommon login(@RequestBody Login login) { Message<String> msg = MessageBuilder.withPayload("Hello RocketMQ ").setHeader(RocketMQHeaders.KEYS, "KEY_").build(); TransactionSendResult result = rmt.sendMessageInTransaction("q2", "q2", msg, login); System.err.println(result); return new DemoCommon(); } @RocketMQTransactionListener(txProducerGroup = "q2") class Xx implements RocketMQLocalTransactionListener { @Override public RocketMQLocalTransactionState executeLocalTransaction(Message msg, Object arg) { Login login = (Login) arg; DemoCommon dc = demoService.selectDemo(login); return RocketMQLocalTransactionState.COMMIT; } @Override public RocketMQLocalTransactionState checkLocalTransaction(Message msg) { return RocketMQLocalTransactionState.COMMIT; } } **请问，这种情况，我想在login方法中获得RocketMQLocalTransactionListener 中返回值DemoCommon，该咋办呢？谢谢。**
---------------------------------------------------------------- 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] With regards, Apache Git Services
