diff --git a/proxy/app_conn.go b/proxy/app_conn.go index f804c97c..5ba1bc15 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 a98419fd..f61fea5f 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)