Skip to content

Commit 60915be

Browse files
Merge pull request #9172 from rabbitmq/mergify/bp/v3.12.x/pr-9165
rabbit_stream_queue: Only update leader PID on stream_leader_change event (backport #9165)
2 parents 2dd2251 + ae5e682 commit 60915be

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
@@ -777,8 +777,7 @@ close(#stream_client{readers = Readers}) ->
777777

778778
update(Q, State)
779779
when ?is_amqqueue(Q) ->
780-
Pid = amqqueue:get_pid(Q),
781-
update_leader_pid(Pid, State).
780+
State.
782781

783782
update_leader_pid(Pid, #stream_client{leader = Pid} = State) ->
784783
State;

0 commit comments

Comments
 (0)