longganhua
2019-07-18 84fe001d1d31101b3aded5535aca3edc2c8544ef
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