From 986c949195d1f50758602f198cae76d56c3b8d56 Mon Sep 17 00:00:00 2001 From: liuxiaolong <liuxiaolong@aiotlink.com> Date: 星期五, 08 一月 2021 18:16:52 +0800 Subject: [PATCH] 如果没有pubTopics或者subTopic,则不启动server接收 --- micronode.go | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/micronode.go b/micronode.go index 88f9bfd..5e105d2 100644 --- a/micronode.go +++ b/micronode.go @@ -22,7 +22,7 @@ SubCh chan *MsgInfo } -func NewMicroNode(ctx context.Context,q chan os.Signal, serverId string, reg *RegisterInfo, procInfo *ProcInfo,fnLog func(v ...interface{})) (*MicroNode, error){ +func NewMicroNode(ctx context.Context,q chan os.Signal, serverId string, reg *RegisterInfo, fnLog func(v ...interface{})) (*MicroNode, error){ conf := NewConfig(KEY_REGISTER,512,5,100,100,100, fnLog) handle, err := Register(ctx, q, conf, reg) if err != nil { @@ -33,7 +33,7 @@ serverId: serverId, handle: handle, reg: reg, - procInfo: procInfo, + procInfo: ®.Proc, fnLog: fnLog, SubCh: make(chan *MsgInfo, 512), } -- Gitblit v1.8.0