I'm trying the transaction example on the website, the executeLocalTransaction
method returns COMMIT_MESSAGE every time.
```java
@Override
public LocalTransactionState executeLocalTransaction(Message msg, Object
arg) {
return LocalTransactionState.COMMIT_MESSAGE;
}
```
The issue is the messages are delayed about 30s(on broker), I'm using 4.3.1 and
2m2s.
Is there any tip about this?
[ Full content available at: https://github.com/apache/rocketmq/issues/474 ]
This message was relayed via gitbox.apache.org for [email protected]
