From 30bbec0a251cb33a01f2693b6da3c92bd5802d50 Mon Sep 17 00:00:00 2001
From: liuxiaolong <liuxiaolong@aiotlink.com>
Date: 星期一, 10 五月 2021 14:32:40 +0800
Subject: [PATCH] add SyncDevToManager
---
client.go | 19 +++++++++++++++----
1 files changed, 15 insertions(+), 4 deletions(-)
diff --git a/client.go b/client.go
index 40f3d17..e4f4704 100644
--- a/client.go
+++ b/client.go
@@ -1,7 +1,8 @@
package bhomedbapi
import (
- "basic.com/valib/bhomebus.git"
+ "basic.com/valib/bhshmq.git/proto/source/bhome_msg"
+ "errors"
"fmt"
"strconv"
)
@@ -43,16 +44,26 @@
}
}
-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 *bhome_msg.MsgRequestTopic,dest []bhome_msg.BHAddress) ([]byte, error) {
+ return nil, errors.New("please init InitDoReq first")
+}
+
+func InitDoReq(fn func(*bhome_msg.MsgRequestTopic, []bhome_msg.BHAddress) ([]byte, error)) {
+ if fn != nil {
+ busReq = fn
+ }
+}
+
func url2Topic(serviceName string, url string) string {
- return url+"_"+serviceName
+ return url
}
\ No newline at end of file
--
Gitblit v1.8.0