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))