This is an automated email from the ASF dual-hosted git repository.

dinglei 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 378f68a  fix typo about _TraceOff (#600)
378f68a is described below

commit 378f68afed58540889c62fb6c85f130ec778cd4a
Author: flaneur <[email protected]>
AuthorDate: Mon Mar 8 20:20:41 2021 +0800

    fix typo about _TraceOff (#600)
    
    Co-authored-by: Li Yazhou <[email protected]>
---
 internal/client.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/internal/client.go b/internal/client.go
index 7e07c5c..e2264a7 100644
--- a/internal/client.go
+++ b/internal/client.go
@@ -39,7 +39,7 @@ const (
        defaultTraceRegionID = "DefaultRegion"
 
        // tracing message switch
-       _TranceOff = "false"
+       _TraceOff = "false"
 
        // Pulling topic information interval from the named server
        _PullNameServerInterval = 30 * time.Second
@@ -587,7 +587,7 @@ func (c *rmqClient) ProcessSendResponse(brokerName string, 
cmd *remote.RemotingC
        resp.QueueOffset = off
        resp.TransactionID = cmd.ExtFields["transactionId"]
        resp.RegionID = regionId
-       resp.TraceOn = trace != "" && trace != _TranceOff
+       resp.TraceOn = trace != "" && trace != _TraceOff
        return nil
 }
 

Reply via email to