fix:callback function execution start context being canceled

apache · Oct 16, 2024 · 2ba2c51 · 2ba2c51
1 parent ac4e3d6
commit 2ba2c51
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/producer/producer.go b/producer/producer.go
@@ -403,7 +403,7 @@ func (p *defaultProducer) sendAsync(ctx context.Context, msg *primitive.Message,
 
 	ctx, cancel := context.WithTimeout(ctx, p.options.SendMsgTimeout)
 	err := p.client.InvokeAsync(ctx, addr, p.buildSendRequest(mq, msg), func(command *remote.RemotingCommand, err error) {
-		cancel()
+		defer cancel()
 		if err != nil {
 			h(ctx, nil, err)
 			return