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 | 5abe1625f4d35672be5e96bf8ea5e12c9339763c (patch) | |
| tree | dc2f703acd5a135c95ea7b43f5d40d1bfb358ef9 | |
| parent | 9f3aff093161a96f9cbd4ca61d6bf06675aec995 (diff) | |
| download | rabbitmq-server-5abe1625f4d35672be5e96bf8ea5e12c9339763c.tar.gz | |
Consume and handle {run_backing_queue, _, _} messages.bug25788
| -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 7683b15a..ee1d2105 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}); |