We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent dcf6d21 commit f871d17Copy full SHA for f871d17
server.go
@@ -916,7 +916,7 @@ func (s *Server) processPublish(cl *Client, pk packets.Packet) error {
916
} else if errors.Is(err, packets.CodeSuccessIgnore) {
917
pk.Ignore = true
918
} else if cl.Properties.ProtocolVersion != 5 || pk.FixedHeader.Qos == 0 {
919
- return nil
+ return err
920
} else if cl.Properties.ProtocolVersion == 5 && pk.FixedHeader.Qos > 0 && errors.As(err, new(packets.Code)) {
921
ackType := packets.Puback
922
if pk.FixedHeader.Qos == 2 {
@@ -927,6 +927,8 @@ func (s *Server) processPublish(cl *Client, pk packets.Packet) error {
927
return err
928
}
929
return nil
930
+ } else {
931
932
933
934
if pk.FixedHeader.Retain { // [MQTT-3.3.1-5] ![MQTT-3.3.1-8]
0 commit comments