diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-06-03 17:12:01 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-06-03 17:12:01 +0100 |
| commit | 679942aed65fcabc67a9cac8991b4e6c0225828a (patch) | |
| tree | bbdea8a8b5cae2e13dca617cd33d78e1454c647d | |
| parent | a7523cda60db961e001834941f452c8391340dd0 (diff) | |
| download | rabbitmq-server-bug25590.tar.gz | |
Remove some unneeded complexity.bug25590
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 11d6a79c..cc06ae44 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -653,8 +653,9 @@ next_state(State = #state{backing_queue = BQ, backing_queue_state = BQS}) -> timed -> {ensure_sync_timer(State1), 0 } end. -backing_queue_timeout(State = #state { backing_queue = BQ }) -> - run_backing_queue(BQ, fun (M, BQS) -> M:timeout(BQS) end, State). +backing_queue_timeout(State = #state { backing_queue = BQ, + backing_queue_state = BQS }) -> + State#state{backing_queue_state = BQ:timeout(BQS)}. ensure_sync_timer(State) -> rabbit_misc:ensure_timer(State, #state.sync_timer_ref, |