From cc9d7e2dfad7c634e8ce69d02ce5fc4065e809e4 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期日, 25 四月 2021 11:34:47 +0800
Subject: [PATCH] 使用bhsgo by lichao
---
client.go | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/client.go b/client.go
index 4c0b558..e4f4704 100644
--- a/client.go
+++ b/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
}
--
Gitblit v1.8.0