使用bhsgo by lichao

liuxiaolong

2021-04-25 cc9d7e2dfad7c634e8ce69d02ce5fc4065e809e4

 client.go

@@ -1,7 +1,7 @@
package bhomedbapi

import (
   "basic.com/valib/bhomebus.git"
   "basic.com/valib/bhshmq.git/proto/source/bhome_msg"
   "errors"
   "fmt"
   "strconv"
@@ -44,21 +44,21 @@
   }
}

var getNetNode = func(topic string) []bhomebus.NetNode{
var getNetNode = func(topic string) []bhome_msg.BHAddress{
   return nil
}

func InitGetNetNode(fn func(name string)[]bhomebus.NetNode) {
func InitGetNetNode(fn func(name string)[]bhome_msg.BHAddress) {
   if fn != nil {
      getNetNode = fn
   }
}

var busReq = func(req []byte,nodes []bhomebus.NetNode) ([]byte, error) {
var busReq = func(req *bhome_msg.MsgRequestTopic,dest []bhome_msg.BHAddress) ([]byte, error) {
   return nil, errors.New("please init InitDoReq first")
}

func InitDoReq(fn func([]byte, []bhomebus.NetNode) ([]byte, error)) {
func InitDoReq(fn func(*bhome_msg.MsgRequestTopic, []bhome_msg.BHAddress) ([]byte, error)) {
   if fn != nil {
      busReq = fn
   }