diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2015-01-08 13:42:10 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2015-01-08 13:42:10 +0000 |
| commit | fbaffc6c54326b4e24171fc9c38220bd77f37597 (patch) | |
| tree | 00be89655dcabcf79d1608d141bb7f094ca2155c /src/rabbit_mirror_queue_sync.erl | |
| parent | a7487e8cc9d166a95aa01625d9650431d6e5511c (diff) | |
| parent | 233ef7c785545f9d390ce1941013942fb5e08af4 (diff) | |
| download | rabbitmq-server-bug26426.tar.gz | |
Merge in defaultbug26426
Diffstat (limited to 'src/rabbit_mirror_queue_sync.erl')
| -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}); |