|
@@ -26,7 +26,7 @@ var funPullHandleStruct func(T_topic string, T_data []byte) error
|
|
|
|
|
|
|
|
/*
|
|
/*
|
|
|
name:服务名称 默认 程序名
|
|
name:服务名称 默认 程序名
|
|
|
-nats: NATS 地址 默认 nats://127.0.0.1:6503
|
|
|
|
|
|
|
+nats: NATS 地址 默认 nats://127.0.0.1:5551
|
|
|
funPH: 平台-> Switch网关方法
|
|
funPH: 平台-> Switch网关方法
|
|
|
*/
|
|
*/
|
|
|
func AiotSwitchInit(name, nats string, funPH func(T_topic string, T_data []byte) error) {
|
|
func AiotSwitchInit(name, nats string, funPH func(T_topic string, T_data []byte) error) {
|
|
@@ -37,7 +37,7 @@ func AiotSwitchInit(name, nats string, funPH func(T_topic string, T_data []byte)
|
|
|
SwitchName = name
|
|
SwitchName = name
|
|
|
|
|
|
|
|
if len(nats) == 0 {
|
|
if len(nats) == 0 {
|
|
|
- nats = "nats://127.0.0.1:6503" // 程序名
|
|
|
|
|
|
|
+ nats = "nats://127.0.0.1:5551" // 程序名
|
|
|
}
|
|
}
|
|
|
funPullHandleStruct = funPH
|
|
funPullHandleStruct = funPH
|
|
|
initNats(nats)
|
|
initNats(nats)
|
