~/Projects/mqtt-go
git clone https://code.lsong.org/mqtt-go
Commit
- Commit
- 4b51e5c7d14fd0aa8ca37105fe8de49b74673a39
- Author
- mochi <[email protected]>
- Date
- 2022-01-24 17:42:33 +0000 +0000
- Diffstat
examples/events/main.go | 10 ++++++++++
Add OnConnect and OnDisconnect hooks to example
diff --git a/examples/events/main.go b/examples/events/main.go
index 45ed004251da1e31791b037a495933b7ce13df39..41cf5b7a91ae229cec796e63cab7a3a968010085 100644
--- a/examples/events/main.go
+++ b/examples/events/main.go
@@ -44,6 +44,16 @@ log.Fatal(err)
}
}()
+ // Add OnConnect Event Hook
+ server.Events.OnConnect = func(cl events.Client, pk events.Packet) {
+ fmt.Printf("<< OnConnect client connected %s: %+v\n", cl.ID, pk)
+ }
+
+ // Add OnDisconnect Event Hook
+ server.Events.OnDisconnect = func(cl events.Client, err error) {
+ fmt.Printf("<< OnDisconnect client dicconnected %s: %v\n", cl.ID, err)
+ }
+
// Add OnMessage Event Hook
server.Events.OnMessage = func(cl events.Client, pk events.Packet) (pkx events.Packet, err error) {
pkx = pk
