~/Projects/mqtt-go
git clone https://code.lsong.org/mqtt-go
Commit
- Commit
- d15ad682bf8ac3618ee254f43903d1bd07da21b4
- Author
- mochi <[email protected]>
- Date
- 2022-01-24 17:42:19 +0000 +0000
- Diffstat
server/server.go | 4 ++++
Call OnDisconnect Event if applicable
diff --git a/server/server.go b/server/server.go
index 9d6b185468cf2285f5247dceec2bac3bde218660..d7056800f11bff3ed9948020a38531007b5d13ca 100644
--- a/server/server.go
+++ b/server/server.go
@@ -274,6 +274,10 @@
atomic.AddInt64(&s.System.ClientsConnected, -1)
atomic.AddInt64(&s.System.ClientsDisconnected, 1)
+ if s.Events.OnDisconnect != nil {
+ s.Events.OnDisconnect(events.FromClient(cl), err)
+ }
+
return err
}
