diff --git a/src/emqx_frame.erl b/src/emqx_frame.erl index 61f8f9e50..ae2ab010d 100644 --- a/src/emqx_frame.erl +++ b/src/emqx_frame.erl @@ -378,7 +378,7 @@ serialize(#mqtt_packet_header{type = Type, retain = Retain}, VariableBin, PayloadBin) when ?CONNECT =< Type andalso Type =< ?AUTH -> Len = iolist_size(VariableBin) + iolist_size(PayloadBin), - true = (Len =< ?MAX_PACKET_SIZE), + (Len =< ?MAX_PACKET_SIZE) orelse error(mqtt_frame_too_large), [<>, serialize_remaining_len(Len), VariableBin, PayloadBin].