From 72c44efd847313481eff96f54206ae311234fabb Mon Sep 17 00:00:00 2001 From: Ethan Buchman Date: Thu, 25 Aug 2016 14:16:28 -0400 Subject: [PATCH] fix query conn --- proxy/app_conn.go | 4 ++++ proxy/multi_app_conn.go | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/proxy/app_conn.go b/proxy/app_conn.go index f804c97cb..5ba1bc158 100644 --- a/proxy/app_conn.go +++ b/proxy/app_conn.go @@ -127,6 +127,10 @@ func (app *appConnQuery) Error() error { return app.appConn.Error() } +func (app *appConnQuery) EchoSync(msg string) (res types.Result) { + return app.appConn.EchoSync(msg) +} + func (app *appConnQuery) InfoSync() (res types.Result) { return app.appConn.InfoSync() } diff --git a/proxy/multi_app_conn.go b/proxy/multi_app_conn.go index a98419fdc..f61fea5f0 100644 --- a/proxy/multi_app_conn.go +++ b/proxy/multi_app_conn.go @@ -114,7 +114,7 @@ func (app *multiAppConn) OnStart() error { if err != nil { return err } - app.queryConn = NewAppConnMempool(querycli) + app.queryConn = NewAppConnQuery(querycli) // mempool connection memcli, err := NewTMSPClient(addr, transport)