diff --git a/deps/rabbit/src/rabbit_msg_store.erl b/deps/rabbit/src/rabbit_msg_store.erl index f706f2f243..ea5e55be4c 100644 --- a/deps/rabbit/src/rabbit_msg_store.erl +++ b/deps/rabbit/src/rabbit_msg_store.erl @@ -1599,7 +1599,7 @@ scan_data(<> = Data, Fd, Fun, Offset, FileSiz end; %% This might be the start of a message. scan_data(<> = Data, Fd, Fun, Offset, FileSize, MsgIdsFound, Acc) - when byte_size(Rest) < Size + 1, Size + 9 =< FileSize - Offset -> + when byte_size(Rest) < Size + 1, Size < FileSize - Offset -> scan(Data, Fd, Fun, Offset, FileSize, MsgIdsFound, Acc); scan_data(Data, Fd, Fun, Offset, FileSize, MsgIdsFound, Acc) when byte_size(Data) < 8 ->