diff --git a/apps/emqx/src/emqx_frame.erl b/apps/emqx/src/emqx_frame.erl index 3e11eae5d..11e39fce6 100644 --- a/apps/emqx/src/emqx_frame.erl +++ b/apps/emqx/src/emqx_frame.erl @@ -174,6 +174,7 @@ parse_remaining_len(<<0:1, Len:7, Rest/binary>>, Header, Multiplier, Value, body_bytes(B) when is_binary(B) -> size(B); body_bytes(?Q(Bytes, _)) -> Bytes. +append_body(H, <<>>) -> H; append_body(H, T) when is_binary(H) andalso size(H) < 1024 -> <>; append_body(H, T) when is_binary(H) ->