diff --git a/broker/client.go b/broker/client.go index 65b7ffa..4d8cc97 100644 --- a/broker/client.go +++ b/broker/client.go @@ -197,9 +197,6 @@ func (c *client) ProcessPublish(packet *packets.PublishPacket) { } func (c *client) ProcessPublishMessage(packet *packets.PublishPacket) { - if c.status == Disconnected { - return - } b := c.broker if b == nil {