liuxiaolong
2021-04-25 c7069befa28a0f2594f0746044318a30d6989c19
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)
}