| commit | 077cd3bcd672e0493fa8707ba3178a9fab1fe089 | [log] [tgz] |
|---|---|---|
| author | yuz10 <845238369@qq.com> | Thu Aug 12 10:50:40 2021 +0800 |
| committer | GitHub <noreply@github.com> | Thu Aug 12 10:50:40 2021 +0800 |
| tree | 50a5e99520225cd50ed504eda344159aabb30c2b | |
| parent | 46701f1d6e4b3fbbbd1e702a0cae9ae947b91da3 [diff] |
Fix send duplicate message in trace interceptor (#709)
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 @@ producerCtx := primitive.GetProducerCtx(ctx) if producerCtx.Message.Topic == dispatcher.GetTraceTopicName() { - return next(ctx, req, reply) + return err } // SendOneway && SendAsync has no reply.