ahaha-vip opened a new issue #414:
URL: https://github.com/apache/rocketmq-spring/issues/414
**FEATURE REQUEST**
1. Please describe the feature you are requesting.
The question is deserialization of `Message` in
`RocketMQLocalTransactionListener#executeLocalTransaction` and
`RocketMQLocalTransactionListener#checkLocalTransaction`, I want to get the
same data structure as I set, but not so, we have to resolve it ourselves. I
think
`RocketMQUtil#convertToSpringMessage(org.apache.rocketmq.common.message.Message)`should
do this, not the user. This logic already exists
`org.apache.rocketmq.spring.support.DefaultRocketMQListenerContainer#doConvertMessage`.
```
public void testSendMessageInTransaction() {
String destination = "test-topic:test-tag";
List<String> payload = CollUtil.newArrayList("1", "2");
Message<List<String>> message =
MessageBuilder.withPayload(payload).build();
rocketMQTemplate.sendMessageInTransaction(destination, message,
payload);
}
public void testRocketMqLocalTransactionListener() {
new RocketMQLocalTransactionListener() {
@Override
public RocketMQLocalTransactionState
executeLocalTransaction(Message msg, Object arg) {
// Custom parameters.
// No problem at this step.
@SuppressWarnings("unchecked")
List<String> customParams = (List<String>) arg;
// Message payload.
//The problem is at this step, I want to get the same data
structure as I set, but not so, we have to resolve it ourselves.
@SuppressWarnings("unchecked")
List<String> payload = (List<String>)msg.getPayload();
// Execute something.
return null;
}
@Override
public RocketMQLocalTransactionState
checkLocalTransaction(Message msg) {
// Check something.
return null;
}
};
}
```
2. Provide any additional detail on your proposed use case for this feature.
3. Indicate the importance of this issue to you (blocker, must-have,
should-have, nice-to-have). Are you currently using any workarounds to address
this issue?
--
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]
