go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-12-24 10:07:04 +02:00
Code Issues Releases Activity

Ignore gRPC Proxy (#1205)

Browse Source
This commit is contained in:
ben-toogood 2020-02-17 08:14:45 +00:00 committed by GitHub
parent 9696efde02
commit 1e40c86dfe
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 0 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
client/grpc/grpc.go
View File

@ -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

5
client/rpc_client.go
View File

@ -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