test callback
This commit is contained in:
parent
29c6a7a4f5
commit
34d5d9a10c
@ -299,7 +299,7 @@ func MQTGCmdWorker(id int, cmds <-chan TGCommand) {
|
|||||||
Body: []byte(j),
|
Body: []byte(j),
|
||||||
})
|
})
|
||||||
logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Publishing message.")
|
logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Publishing message.")
|
||||||
//log.Printf("MQTGCmdWorker[" + strconv.Itoa(id) + "] : Message published.")
|
log.Printf("MQTGCmdWorker[" + strconv.Itoa(id) + "] : Message published.")
|
||||||
clt.Mux.Unlock()
|
clt.Mux.Unlock()
|
||||||
} else {
|
} else {
|
||||||
log.Printf("MQTGCmdWorker["+strconv.Itoa(id)+"] : client %d offline.\n", c.FromUserID64)
|
log.Printf("MQTGCmdWorker["+strconv.Itoa(id)+"] : client %d offline.\n", c.FromUserID64)
|
||||||
|
Loading…
Reference in New Issue
Block a user