Skip to content

Commit 3d5985e

Browse files
committed
fixup! WIP Remove CQv1
1 parent 9edbe65 commit 3d5985e

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

deps/rabbit/src/rabbit_variable_queue.erl

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -717,6 +717,17 @@ handle_pre_hibernate(State = #vqstate{ msg_store_clients = MSCState0 }) ->
717717
MSCState = msg_store_pre_hibernate(MSCState0),
718718
sync(State#vqstate{ msg_store_clients = MSCState }).
719719

720+
sync(State = #vqstate { index_state = IndexState0,
721+
store_state = StoreState0,
722+
unconfirmed_simple = UCS,
723+
confirmed = C }) ->
724+
IndexState = rabbit_classic_queue_index_v2:sync(IndexState0),
725+
StoreState = rabbit_classic_queue_store_v2:sync(StoreState0),
726+
State #vqstate { index_state = IndexState,
727+
store_state = StoreState,
728+
unconfirmed_simple = sets:new([{version,2}]),
729+
confirmed = sets:union(C, UCS) }.
730+
720731
resume(State) -> a(timeout(State)).
721732

722733
msg_rates(#vqstate { rates = #rates { in = AvgIngressRate,

0 commit comments

Comments
 (0)