hbusc.go | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
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()