strip Micro-Topic header from incoming context in client.Call (#1177)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
parent
f0f7f860d6
commit
99807a680c
@ -74,6 +74,11 @@ func (r *rpcClient) call(ctx context.Context, node *registry.Node, req Request,
|
|||||||
md, ok := metadata.FromContext(ctx)
|
md, ok := metadata.FromContext(ctx)
|
||||||
if ok {
|
if ok {
|
||||||
for k, v := range md {
|
for k, v := range md {
|
||||||
|
// don't copy Micro-Topic header, that used for pub/sub
|
||||||
|
// this fix case then client uses the same context that received in subscriber
|
||||||
|
if k == "Micro-Topic" {
|
||||||
|
continue
|
||||||
|
}
|
||||||
msg.Header[k] = v
|
msg.Header[k] = v
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user