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

tigerlee 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 a22cfcb  [ISSUE #1102] fix send async err occur panic: runtime error: 
invalid memory address or nil pointer dereference
     new 49f0448  Merge pull request #1104 from 474903784/fix_send_async
a22cfcb is described below

commit a22cfcbcd54964b0cc403725ef54689fcbf0c191
Author: liuwenxing <liuwenx...@mini1.cn>
AuthorDate: Thu Oct 19 16:00:03 2023 +0800

    [ISSUE #1102] fix send async err occur panic: runtime error: invalid memory 
address or nil pointer dereference
---
 producer/producer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/producer/producer.go b/producer/producer.go
index d8ca54b..915a573 100644
--- a/producer/producer.go
+++ b/producer/producer.go
@@ -405,6 +405,7 @@ func (p *defaultProducer) sendAsync(ctx context.Context, 
msg *primitive.Message,
                cancel()
                if err != nil {
                        h(ctx, nil, err)
+                       return
                }
 
                resp := primitive.NewSendResult()

Reply via email to