apps/mochi-mqtt
1
0
Fork 0
mirror of https://github.com/mochi-mqtt/server.git synced 2025-10-27 18:10:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

Ensure OnError is set before using it

Browse Source
This commit is contained in:
mochi
2022-03-31 17:56:08 +01:00
parent da2fd41f79
commit 01d8a450d2
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/server.go
View File

@@ -484,9 +484,11 @@ func (s *Server) processPublish(cl *clients.Client, pk packets.Packet) error {
return nil return nil
} }
if s.Events.OnError != nil {
s.Events.OnError(cl.Info(), err) s.Events.OnError(cl.Info(), err)
} }
} }
}
if pk.FixedHeader.Retain { if pk.FixedHeader.Retain {
s.retainMessage(cl, pk) s.retainMessage(cl, pk)