This is an automated email from the ASF dual-hosted git repository.
yuzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 83df64e fix decode CheckTransactionStateRequestHeader (#1225)
83df64e is described below
commit 83df64e17e19ad68f2c4e31432e1f91911663b80
Author: wsy6543 <[email protected]>
AuthorDate: Wed Nov 12 15:20:02 2025 +0800
fix decode CheckTransactionStateRequestHeader (#1225)
---
internal/request.go | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/internal/request.go b/internal/request.go
index 93d7a5d..ab2c93b 100644
--- a/internal/request.go
+++ b/internal/request.go
@@ -175,10 +175,10 @@ func (request *CheckTransactionStateRequestHeader)
Decode(properties map[string]
request.MsgId = v
}
if v, existed := properties["transactionId"]; existed {
- request.MsgId = v
+ request.TransactionId = v
}
if v, existed := properties["offsetMsgId"]; existed {
- request.MsgId = v
+ request.OffsetMsgId = v
}
}