| | |
|---|
| | | //获取本机中某一个主题的 key （结果只有一个元素） |
|---|
| | | func (ms *MicroNode) GetLocalNetNodeByTopic(topicName string) []bhomebus.NetNode { |
|---|
| | | netNodes, err := ms.handle.GetNetNodeByTopic(ms.serverId, ms.procInfo, topicName) |
|---|
| | | ms.printLog("netNodes:", netNodes, "err:", err) |
|---|
| | | if err != nil { |
|---|
| | | ms.printLog("netNodes:", netNodes, "err:", err) |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | | return netNodes |
|---|
| | |
|---|
| | | Topic: TOPIC_QUERYPROC, |
|---|
| | | } |
|---|
| | | cr, err := ms.handle.RequestCenter(&r) |
|---|
| | | ms.printLog("requestCenter reply:", cr, "err:", err) |
|---|
| | | if err != nil { |
|---|
| | | ms.printLog("requestCenter reply:", cr, "err:", err) |
|---|
| | | return nil, err |
|---|
| | | } |
|---|
| | | if cr.Status == REPLY_SUCCESS && cr.Body != nil { |
|---|
