liuxiaolong
2021-09-03 c6ca4f8295ee423b05c8b28695dde45b5c37e842
hbusc.go
@@ -173,7 +173,7 @@
         wg.Done()
         return
      default:
         if bhsgo.ReadSub(&procId, &msg, 100) {
         if bhsgo.ReadSub(&procId, &msg, -1) {
            ch <- msg
            logFn("ReadSub topic:", string(msg.Topic), " data:", string(msg.Data))