From 7b9bc844c104ca6818c8efdc09f48c06bbaf8e17 Mon Sep 17 00:00:00 2001 From: mochi Date: Thu, 31 Mar 2022 17:52:40 +0100 Subject: [PATCH] Add ErrRejectPacket error to abandon packet processing from OnMessageProcess --- server/server.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/server/server.go b/server/server.go index 1afd95e..66af3d3 100644 --- a/server/server.go +++ b/server/server.go @@ -41,6 +41,9 @@ var ( // ErrInvalidTopic indicates that the specified topic was not valid. 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") ErrClientReconnect = errors.New("Client attemped to reconnect") ErrServerShutdown = errors.New("Server is shutting down")