diff options
| -rw-r--r-- | src/rabbit_disk_queue.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_disk_queue.erl b/src/rabbit_disk_queue.erl index d712142adf..d88eea1b07 100644 --- a/src/rabbit_disk_queue.erl +++ b/src/rabbit_disk_queue.erl @@ -1998,9 +1998,8 @@ read_next_file_entry(FileHdl, Offset) -> {ok, <<MsgId:MsgIdBinSize/binary>>} -> ExpectedAbsPos = Offset + ?FILE_PACKING_ADJUSTMENT + TotalSize - 1, - case file:position(FileHdl, - {cur, TotalSize - MsgIdBinSize} - ) of + case file:position( + FileHdl, {cur, TotalSize - MsgIdBinSize}) of {ok, ExpectedAbsPos} -> NextOffset = Offset + TotalSize + ?FILE_PACKING_ADJUSTMENT, |