Skip to content

Commit 3104923

Browse files
add missing clause for v != 5 + qos = 0
1 parent 2522fac commit 3104923

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

server.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -913,6 +913,8 @@ func (s *Server) processPublish(cl *Client, pk packets.Packet) error {
913913
pkx, err := s.hooks.OnPublish(cl, pk)
914914
if err == nil {
915915
pk = pkx
916+
} else if errors.Is(err, packets.ErrRejectPacket) && (cl.Properties.ProtocolVersion != 5 || pk.FixedHeader.Qos == 0) {
917+
return nil
916918
} else if errors.Is(err, packets.CodeSuccessIgnore) {
917919
pk.Ignore = true
918920
} else if cl.Properties.ProtocolVersion == 5 && pk.FixedHeader.Qos > 0 && errors.As(err, new(packets.Code)) {

0 commit comments

Comments
 (0)