1
2
3
4
5
6
7
8
9
10
11
12
13
| package mc
|
| import "basic.com/valib/bhomebus.git"
|
| type Broker interface {
| //发布到本机
| Publish(topic string, msg []byte) error
|
| //发布到远程机器
| PublishNet(nodes []bhomebus.NetNode, topic string, msg []byte) error
|
| Subscribe(topics []string) chan []byte
| }
|
|