Browse Source

fix query conn

pull/266/head
Ethan Buchman 8 years ago
parent
commit
72c44efd84
2 changed files with 5 additions and 1 deletions
  1. +4
    -0
      proxy/app_conn.go
  2. +1
    -1
      proxy/multi_app_conn.go

+ 4
- 0
proxy/app_conn.go View File

@ -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()
}


+ 1
- 1
proxy/multi_app_conn.go View File

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


Loading…
Cancel
Save