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 26e13b7 fix(sendOneWay): fix stack overflow caused by recursive calls
(#773)
26e13b7 is described below
commit 26e13b7bd9e7f97b739c63ed32509ab1ed97f2e4
Author: Wen Hu <[email protected]>
AuthorDate: Tue Jul 12 14:27:32 2022 +0800
fix(sendOneWay): fix stack overflow caused by recursive calls (#773)
Co-authored-by: huwen.alvin <[email protected]>
---
producer/producer.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/producer/producer.go b/producer/producer.go
index feec282..5ebf5d0 100644
--- a/producer/producer.go
+++ b/producer/producer.go
@@ -383,7 +383,7 @@ func (p *defaultProducer) SendOneWay(ctx context.Context,
msgs ...*primitive.Mes
if p.interceptor != nil {
primitive.WithMethod(ctx, primitive.SendOneway)
return p.interceptor(ctx, msg, nil, func(ctx context.Context,
req, reply interface{}) error {
- return p.SendOneWay(ctx, msg)
+ return p.sendOneWay(ctx, msg)
})
}