Ignore gRPC Proxy (#1205)
This commit is contained in:
parent
4a6f438db2
commit
5b60299d47
5
grpc.go
5
grpc.go
@ -576,11 +576,6 @@ func (g *grpcClient) Publish(ctx context.Context, p client.Message, opts ...clie
|
|||||||
|
|
||||||
topic := p.Topic()
|
topic := p.Topic()
|
||||||
|
|
||||||
// get proxy topic
|
|
||||||
if prx := os.Getenv("MICRO_PROXY"); len(prx) > 0 {
|
|
||||||
options.Exchange = prx
|
|
||||||
}
|
|
||||||
|
|
||||||
// get the exchange
|
// get the exchange
|
||||||
if len(options.Exchange) > 0 {
|
if len(options.Exchange) > 0 {
|
||||||
topic = options.Exchange
|
topic = options.Exchange
|
||||||
|
Loading…
Reference in New Issue
Block a user