[pulsar-client-go] branch master updated: [Fix] return when registerSendOrAckOp() failed (#1045)

[zike]

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

zike pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-client-go.git


The following commit(s) were added to refs/heads/master by this push:
     new aa66471  [Fix] return when registerSendOrAckOp() failed (#1045)
aa66471 is described below

commit aa664716ac0bfb886c756f33ba72376092e8e3a5
Author: gunli <24350...@qq.com>
AuthorDate: Wed Jul 5 10:20:03 2023 +0800

    [Fix] return when registerSendOrAckOp() failed (#1045)
    
    Master Issue: #1040
    
    ### Motivation
    
    
    fix #1040, return when registerSendOrAckOp() return an error.
    
    ### Modifications
    
    - modified: pulsar/producer_partition.go
    
    ---------
    
    Co-authored-by: gunli <gu...@tencent.com>
---
 pulsar/producer_partition.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
index 012bfd9..595cab4 100755
--- a/pulsar/producer_partition.go
+++ b/pulsar/producer_partition.go
@@ -1126,6 +1126,7 @@ func (p *partitionProducer) internalSendAsync(ctx 
context.Context, msg *Producer
                }
                if err := transactionImpl.registerSendOrAckOp(); err != nil {
                        runCallback(callback, nil, msg, err)
+                       return
                }
                newCallback = func(id MessageID, producerMessage 
*ProducerMessage, err error) {
                        runCallback(callback, id, producerMessage, err)