liuxiaolong
2021-04-26 3cacb780e1101022604ea4c4dd44c455151d29dc
hbusc.go
@@ -54,6 +54,7 @@
               src,
            }
            logFn("ReadRequest topic:", string(msg.Topic), " data:", string(msg.Data))
            procId = ""
            msg.Reset()
            src = unsafe.Pointer(nil)
@@ -158,6 +159,7 @@
      default:
         if bhsgo.ReadSub(&procId, &msg, 100) {
            ch <- msg
            logFn("ReadSub topic:", string(msg.Topic), " data:", string(msg.Data))
            procId = ""
            msg.Reset()