command/query.go
@@ -164,11 +164,11 @@ handler.AckReceived(a) case r := <-respCh: fmt.Println("enter respch: r.payload", len(r.Payload)) if r.From == "" { break OUTER } handler.ResponseReceived(r) fmt.Println("enter respch: r.payload", len(r.Payload)) case <-c.ShutdownCh: return 1