diff --git a/broker.go b/broker.go index cf58bab..fc77a85 100644 --- a/broker.go +++ b/broker.go @@ -363,6 +363,7 @@ func (br *broker) run() { if dev, ok := br.getDevice(devid); ok { dev.WriteMsg(msgTypeHeartbeat, []byte{}) } + case req := <-br.cmdReq: if dev, ok := br.getDevice(req.devid); ok { dev.WriteMsg(msgTypeCmd, req.data)