Fix send duplicate message in trace interceptor (#709)

yuz10 · web-flow · commit 077cd3bcd672 · 2021-08-12T10:50:40.000+08:00
diff --git 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.

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ func newTraceInterceptor(traceCfg *primitive.TraceConfig) primitive.Interceptor`
`50`	`50`
`51`	`51`	`producerCtx := primitive.GetProducerCtx(ctx)`
`52`	`52`	`if producerCtx.Message.Topic == dispatcher.GetTraceTopicName() {`
`53`		`- return next(ctx, req, reply)`
	`53`	`+ return err`
`54`	`54`	`}`
`55`	`55`
`56`	`56`	`// SendOneway && SendAsync has no reply.`