| | |
| | | package bhomedbapi |
| | | |
| | | import ( |
| | | "basic.com/valib/bhshmq.git/proto/source/bhome_msg" |
| | | "basic.com/valib/c_bhomebus.git/proto/source/bhome_msg" |
| | | "errors" |
| | | "fmt" |
| | | "strconv" |
| | |
| | | return nil |
| | | } |
| | | |
| | | var n_getNetNode = func(topic string) []*bhome_msg.MsgQueryTopicReply_BHNodeAddress{ |
| | | return nil |
| | | } |
| | | |
| | | func InitGetNetNode(fn func(name string)[]*bhome_msg.MsgQueryTopicReply_BHNodeAddress) { |
| | | //if fn != nil { |
| | | // getNetNode = fn |
| | | //} |
| | | if fn != nil { |
| | | n_getNetNode = fn |
| | | } |
| | | } |
| | | |
| | | var busReq = func(req *bhome_msg.MsgRequestTopic,dest []*bhome_msg.MsgQueryTopicReply_BHNodeAddress) ([]byte, error) { |