[GitHub] [rocketmq-spring] Dreamroute opened a new issue #58: 事务消息返回值问题

[GitBox <gi...@apache.org>]

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:
users@infra.apache.org


With regards,
Apache Git Services