liuxiaolong
2021-09-27 545fb87bae9b38f04495c6ac311f6ba651720b44
hbusc.go
@@ -167,11 +167,11 @@
   for {
      select {
      case <-ctx.Done():
         logFn("recvRoutine ctx.Done")
         logFn("recvSubRoutine ctx.Done")
         wg.Done()
         return
      default:
         if bhsgo.ReadSub(&procId, &msg, -1) {
         if bhsgo.ReadSub(&procId, &msg, 100) {
            ch <- msg
            logFn("ReadSub topic:", string(msg.Topic), " data:", string(msg.Data))