This is an automated email from the ASF dual-hosted git repository.
yuzhou 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 077cd3b Fix send duplicate message in trace interceptor (#709)
077cd3b is described below
commit 077cd3bcd672e0493fa8707ba3178a9fab1fe089
Author: yuz10 <[email protected]>
AuthorDate: Thu Aug 12 10:50:40 2021 +0800
Fix send duplicate message in trace interceptor (#709)
---
producer/interceptor.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/producer/interceptor.go b/producer/interceptor.go
index b3d2598..160deac 100644
--- a/producer/interceptor.go
+++ b/producer/interceptor.go
@@ -50,7 +50,7 @@ func newTraceInterceptor(traceCfg *primitive.TraceConfig)
primitive.Interceptor
producerCtx := primitive.GetProducerCtx(ctx)
if producerCtx.Message.Topic == dispatcher.GetTraceTopicName() {
- return next(ctx, req, reply)
+ return err
}
// SendOneway && SendAsync has no reply.
