diff options
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 4cb534ff..a80f8f50 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -123,7 +123,7 @@ syncer_loop({Ref, MPid} = Args, SPidsMRefs) -> {msg, Ref, Msg, MsgProps} -> SPidsMRefs1 = wait_for_credit(SPidsMRefs, Ref), [begin - credit_flow:send(SPid, ?CREDIT_DISC_BOUND), + credit_flow:send(SPid), SPid ! {sync_msg, Ref, Msg, MsgProps} end || {SPid, _} <- SPidsMRefs1], syncer_loop(Args, SPidsMRefs1); @@ -205,7 +205,7 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, {TRef1, BQS1} = UpdateRamDuration(BQ, BQS), slave_sync_loop(Args, TRef1, BQS1); {sync_msg, Ref, Msg, Props} -> - credit_flow:ack(Syncer, ?CREDIT_DISC_BOUND), + credit_flow:ack(Syncer), Props1 = Props#message_properties{needs_confirming = false}, BQS1 = BQ:publish(Msg, Props1, true, none, BQS), slave_sync_loop(Args, TRef, BQS1); |