command/query.go
@@ -107,6 +107,7 @@ payload = []byte(args[1]) } fmt.Println("query send len payload", len(payload)) cl, err := RPCClient(*rpcAddr, *rpcAuth) if err != nil { c.Ui.Error(fmt.Sprintf("Error connecting to Serf agent: %s", err)) @@ -167,7 +168,7 @@ break OUTER } handler.ResponseReceived(r) return 0 fmt.Println("enter respch: r.payload", r.Payload) case <-c.ShutdownCh: return 1
