Skip to content

Commit 6b8fcd6

Browse files
Fix a test #12468 #15215
1 parent 8def0a0 commit 6b8fcd6

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

deps/rabbit/src/rabbit_quorum_queue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2140,7 +2140,7 @@ force_shrink_member_to_current_member(VHost, Name) ->
21402140
Fun = fun (Q0) ->
21412141
TS0 = amqqueue:get_type_state(Q0),
21422142
TS = TS0#{nodes => [Node]},
2143-
amqqueue:set_type_state(Q, TS)
2143+
amqqueue:set_type_state(Q0, TS)
21442144
end,
21452145
_ = rabbit_amqqueue:update(QName, Fun),
21462146
_ = [ra:force_delete_server(?RA_SYSTEM, {RaName, N}) || N <- OtherNodes],

0 commit comments

Comments
 (0)