From 1faa5ab7e0c392f12cc867327ff501a3d4374676 Mon Sep 17 00:00:00 2001 From: Chuntao Lu Date: Mon, 3 Apr 2017 11:59:49 -0700 Subject: [PATCH] Allocate subchannel for new client --- examples/example-gateway/clients/baz/baz.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/examples/example-gateway/clients/baz/baz.go b/examples/example-gateway/clients/baz/baz.go index ef64a6377..f18ff41a8 100644 --- a/examples/example-gateway/clients/baz/baz.go +++ b/examples/example-gateway/clients/baz/baz.go @@ -28,13 +28,13 @@ func NewClient(config *zanzibar.StaticConfig, gateway *zanzibar.Gateway) *BazCli // TODO: (lu) get serviceName from thrift serviceName := "SimpleService" - ch := gateway.Channel + sc := gateway.Channel.GetSubChannel(serviceName) ip := config.MustGetString("clients.baz.ip") port := config.MustGetInt("clients.baz.port") - ch.Peers().Add(ip + ":" + strconv.Itoa(int(port))) + sc.Peers().Add(ip + ":" + strconv.Itoa(int(port))) - client := zt.NewClient(ch, serviceName) + client := zt.NewClient(gateway.Channel, serviceName) return &BazClient{ thriftService: serviceName,