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
        }
 }
 

Reply via email to