diff options
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 6ddfc3a3ad..3e45f02638 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -826,7 +826,7 @@ process_instruction({fetch, AckRequired, MsgId, Remaining}, backing_queue_state = BQS }) -> QLen = BQ:len(BQS), {State1, Delta} = - case {QLen - 1} of + case QLen - 1 of Remaining -> {{#basic_message{id = MsgId}, _IsDelivered, AckTag, Remaining}, BQS1} = BQ:fetch(AckRequired, BQS), @@ -936,7 +936,7 @@ set_synchronised(Delta, AddAnyway, Q1#amqqueue{sync_slave_pids = [Self | SSPids1]}) end end); - _ when DepthDelta1 > 0 -> + _ when DepthDelta1 >= 0 -> ok end, State #state { depth_delta = DepthDelta1 }. |