Skip to content

Commit 8a9d949

Browse files
Merge pull request #9173 from rabbitmq/mergify/bp/v3.11.x/pr-9172
rabbit_stream_queue: Only update leader PID on stream_leader_change event (backport #9165) (backport #9172)
2 parents 6ed19aa + 540c028 commit 8a9d949

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

deps/rabbit/src/rabbit_stream_queue.erl

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -768,8 +768,7 @@ close(#stream_client{readers = Readers}) ->
768768

769769
update(Q, State)
770770
when ?is_amqqueue(Q) ->
771-
Pid = amqqueue:get_pid(Q),
772-
update_leader_pid(Pid, State).
771+
State.
773772

774773
update_leader_pid(Pid, #stream_client{leader = Pid} = State) ->
775774
State;

0 commit comments

Comments
 (0)