修改Subcribe接口

liuxiaolong

2020-12-30 b1dc3bfe7b9ef852fdf9ca23fdd6646ca65d463d

修改Subcribe接口

 broker.go

@@ -9,5 +9,5 @@
    //发布到远程机器
    PublishNet(nodes []bhomebus.NetNode, topic string, msg []byte) error

    Subscribe(topics []string) chan []byte
    Subscribe(topics []string)
}

 micronode.go

@@ -259,9 +259,8 @@
    return ms.handle.Pub(nodes, pi)
}

func (ms *MicroNode) Subscribe(topics []string) chan []byte {
    ch := make(chan []byte)
    return ch
func (ms *MicroNode) Subscribe(topics []string) {
    ms.handle.Sub(topics)
}

//free handle