Merge pull request #11288 from rabbitmq/loic-fix-fan-out-pread-crash-…

…main CQ: Fix entry missing from cache leading to crash on read
rabbitmq · May 21, 2024 · 6047583 · 6047583
2 parents 8f19a04 + 93e4e88
commit 6047583
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/deps/rabbit/src/rabbit_msg_store.erl b/deps/rabbit/src/rabbit_msg_store.erl
@@ -907,7 +907,7 @@ handle_cast({write, CRef, MsgRef, MsgId, Flow},
             %% the normal logic for that in write_message/4 and
             %% maybe_roll_to_new_file/2.
             case index_lookup(MsgId, State) of
-                [#msg_location { file = File }]
+                #msg_location { file = File }
                   when File == State #msstate.current_file ->
                     ok;
                 _ ->