add PublishNetTimeout

liuxiaolong

2021-02-05 7cf6b23c83e1c4efb8567a16ab2f401be4b6d1bf

 micronode.go

@@ -241,6 +241,14 @@
   return ms.handle.Pub(nodes, pi)
}

func (ms *MicroNode) PublishNetTimeout(nodes []bhomebus.NetNode, topic string, msg []byte, timeout int) int {
   pi := &MsgInfo{
      Topic: topic,
      Body: msg,
   }
   return ms.handle.PubTimeout(nodes, pi, timeout)
}

//订阅主题
func (ms *MicroNode) Subscribe(topics []string) {
   ms.handle.Sub(topics)