diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-11-14 16:37:09 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-11-14 16:37:09 +0000 |
| commit | e286b845da707d065574a9a931c804ef2c0714bb (patch) | |
| tree | dc2f703acd5a135c95ea7b43f5d40d1bfb358ef9 | |
| parent | 48c68e40704ed105b76c23ea66c9e49f49addd38 (diff) | |
| download | rabbitmq-server-git-e286b845da707d065574a9a931c804ef2c0714bb.tar.gz | |
Consume and handle {run_backing_queue, _, _} messages.
| -rw-r--r-- | src/rabbit_mirror_queue_sync.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_sync.erl b/src/rabbit_mirror_queue_sync.erl index 7683b15ad0..ee1d210556 100644 --- a/src/rabbit_mirror_queue_sync.erl +++ b/src/rabbit_mirror_queue_sync.erl @@ -252,6 +252,9 @@ slave_sync_loop(Args = {Ref, MRef, Syncer, BQ, UpdateRamDuration, Parent}, {'$gen_cast', {set_ram_duration_target, Duration}} -> BQS1 = BQ:set_ram_duration_target(Duration, BQS), slave_sync_loop(Args, {MA, TRef, BQS1}); + {'$gen_cast', {run_backing_queue, Mod, Fun}} -> + BQS1 = BQ:invoke(Mod, Fun, BQS), + slave_sync_loop(Args, {MA, TRef, BQS1}); update_ram_duration -> {TRef1, BQS1} = UpdateRamDuration(BQ, BQS), slave_sync_loop(Args, {MA, TRef1, BQS1}); |