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

Add ErrRejectPacket error to abandon packet processing from OnMessageProcess

Browse Source
This commit is contained in:
mochi
2022-03-31 17:52:40 +01:00
parent 8acb182820
commit 7b9bc844c1
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/server.go
View File

@@ -41,6 +41,9 @@ var (
// ErrInvalidTopic indicates that the specified topic was not valid. // ErrInvalidTopic indicates that the specified topic was not valid.
ErrInvalidTopic = errors.New("cannot publish to $ and $SYS topics") ErrInvalidTopic = errors.New("cannot publish to $ and $SYS topics")
// ErrRejectPacket indicates that a packet should be dropped instead of processed.
ErrRejectPacket = errors.New("packet rejected")
ErrClientDisconnect = errors.New("Client disconnected") ErrClientDisconnect = errors.New("Client disconnected")
ErrClientReconnect = errors.New("Client attemped to reconnect") ErrClientReconnect = errors.New("Client attemped to reconnect")
ErrServerShutdown = errors.New("Server is shutting down") ErrServerShutdown = errors.New("Server is shutting down")