diff --git a/go.mod b/go.mod index afe5611..436540b 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,6 @@ module zhub -go 1.15 +go 1.16 require ( github.com/go-sql-driver/mysql v1.5.0 diff --git a/zsub/msg-consumer.go b/zsub/msg-consumer.go index da8fcd2..2dcdc87 100644 --- a/zsub/msg-consumer.go +++ b/zsub/msg-consumer.go @@ -55,7 +55,7 @@ func msgAccept(v Message) { return case "publish": if len(rcmd) != 3 { - c.send("-Error: publish para number!") + c.send("-Error: publish para number![" + strings.Join(rcmd, " ") + "]") } else { zsub.publish(rcmd[1], rcmd[2]) } diff --git a/zsub/zsub.go b/zsub/zsub.go index 4a53cbb..ef9362b 100644 --- a/zsub/zsub.go +++ b/zsub/zsub.go @@ -168,7 +168,7 @@ func (c *ZConn) appendTo(arr []*ZConn) []*ZConn { return append(arr, c) } -// ================== ZHub server ===================================== +// ServerStart ================== ZHub server ===================================== /* 1、初始化服务 2、启动服务监听