cmd/TST/test/test.go
@@ -55,6 +55,7 @@ } return nil }) // go c.Run("192.168.20.108:4150", 2) go c.RunLookupd("192.168.20.108:4161", 2) @@ -67,8 +68,11 @@ } func Test() { go produce(true) two := false go produce(two) go consume("test2", "sensor01") if two { go consume("test2", "sensor01") } consume("test", "sensor01") }