broker.go
@@ -1,17 +1,17 @@ package bhomeclient import "basic.com/valib/bhomebus.git" import "basic.com/valib/bhshmq.git/proto/source/bhome_msg" type Broker interface { //发布到本机 Publish(topic string, msg []byte) error Publish(string, []byte) error //发布到远程机器 PublishNet(nodes []bhomebus.NetNode, topic string, msg []byte) error PublishNet([]bhome_msg.BHAddress, string, []byte) error //订阅一些主题,可动态新增 Subscribe(topics []string) Subscribe([]string) //注销订阅的主题 DeSub(topics []string) DeSub([]string) }