diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index c195111355c..3d1a08b8893 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/deps/rabbit/src/rabbit_stream_queue.erl @@ -768,8 +768,7 @@ close(#stream_client{readers = Readers}) -> update(Q, State) when ?is_amqqueue(Q) -> - Pid = amqqueue:get_pid(Q), - update_leader_pid(Pid, State). + State. update_leader_pid(Pid, #stream_client{leader = Pid} = State) -> State;