From 1e40c86dfe16db38146a9647f4dcc3cb001da9bc Mon Sep 17 00:00:00 2001 From: ben-toogood Date: Mon, 17 Feb 2020 08:14:45 +0000 Subject: [PATCH] Ignore gRPC Proxy (#1205) --- client/grpc/grpc.go | 5 ----- client/rpc_client.go | 5 ----- 2 files changed, 10 deletions(-) diff --git a/client/grpc/grpc.go b/client/grpc/grpc.go index e90386ac..1c7f3512 100644 --- a/client/grpc/grpc.go +++ b/client/grpc/grpc.go @@ -576,11 +576,6 @@ func (g *grpcClient) Publish(ctx context.Context, p client.Message, opts ...clie topic := p.Topic() - // get proxy topic - if prx := os.Getenv("MICRO_PROXY"); len(prx) > 0 { - options.Exchange = prx - } - // get the exchange if len(options.Exchange) > 0 { topic = options.Exchange diff --git a/client/rpc_client.go b/client/rpc_client.go index 0eda7232..b701d1ca 100644 --- a/client/rpc_client.go +++ b/client/rpc_client.go @@ -610,11 +610,6 @@ func (r *rpcClient) Publish(ctx context.Context, msg Message, opts ...PublishOpt // set the topic topic := msg.Topic() - // get proxy - if prx := os.Getenv("MICRO_PROXY"); len(prx) > 0 { - options.Exchange = prx - } - // get the exchange if len(options.Exchange) > 0 { topic = options.Exchange