louis/oktopus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: page for broker SYS info

Browse Source
This commit is contained in:
Leandro Antônio Farias Machado 2023-05-07 10:55:15 -03:00
parent 09acc57689
commit bf000a65c5
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
backend/services/mochi/cmd/main.go
View File

@ -38,7 +38,7 @@ func main() {
tcpAddr := flag.String("tcp", ":1883", "network address for TCP listener") tcpAddr := flag.String("tcp", ":1883", "network address for TCP listener")
redisAddr := flag.String("redis", "172.17.0.2:6379", "host address of redis db") redisAddr := flag.String("redis", "172.17.0.2:6379", "host address of redis db")
wsAddr := flag.String("ws", "", "network address for Websocket listener") wsAddr := flag.String("ws", "", "network address for Websocket listener")
infoAddr := flag.String("info", "", "network address for web info dashboard listener") infoAddr := flag.String("info", ":8080", "network address for web info dashboard listener")
path := flag.String("path", "", "path to data auth file") path := flag.String("path", "", "path to data auth file")
flag.Parse() flag.Parse()
@ -158,8 +158,7 @@ func (h *MyHook) OnDisconnect(cl *mqtt.Client, err error, expire bool) {
} }
if clUser != "" { if clUser != "" {
sn := strings.Split(clUser, "-") err := server.Publish("oktopus/disconnect", []byte(clUser), false, 1)
err := server.Publish("oktopus/disconnect", []byte(sn[1]), false, 1)
if err != nil { if err != nil {
log.Println("server publish error: ", err) log.Println("server publish error: ", err)
} }