Skip to content

Commit b4667e3

Browse files
author
Francesco Mazzoli
committed
AckMsgs -> AckRequired in master:purge
1 parent 6d4f453 commit b4667e3

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/rabbit_mirror_queue_master.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -176,7 +176,7 @@ dropwhile(Pred, AckRequired,
176176
Len = BQ:len(BQS),
177177
{Msgs, BQS1} = BQ:dropwhile(Pred, AckRequired, BQS),
178178
Len1 = BQ:len(BQS1),
179-
ok = gm:broadcast(GM, {set_length, Len1, AckMsgs}),
179+
ok = gm:broadcast(GM, {set_length, Len1, AckRequired}),
180180
Dropped = Len - Len1,
181181
SetDelivered1 = lists:max([0, SetDelivered - Dropped]),
182182
{Msgs, State #state { backing_queue_state = BQS1,

0 commit comments

Comments
 (0)