This is an automated email from the ASF dual-hosted git repository. huangli pushed a commit to branch 4.9.2_dev_community in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 50c1da38720b1132d45bfde67d8aa6a05d47bac5 Author: sunshuangcheng <[email protected]> AuthorDate: Mon Nov 22 12:53:46 2021 +0800 使slave状态不影响事务消息发送 --- .../apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java index 117a8c6..cdb6836 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java @@ -1351,6 +1351,8 @@ public class DefaultMQProducerImpl implements MQProducerInner { LocalTransactionState localTransactionState = LocalTransactionState.UNKNOW; Throwable localException = null; switch (sendResult.getSendStatus()) { + case FLUSH_SLAVE_TIMEOUT: + case SLAVE_NOT_AVAILABLE: case SEND_OK: { try { if (sendResult.getTransactionId() != null) { @@ -1380,10 +1382,8 @@ public class DefaultMQProducerImpl implements MQProducerInner { localException = e; } } - break; + break; case FLUSH_DISK_TIMEOUT: - case FLUSH_SLAVE_TIMEOUT: - case SLAVE_NOT_AVAILABLE: localTransactionState = LocalTransactionState.ROLLBACK_MESSAGE; break; default:
