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 | 46474125f27ac435682ca85e4d621697bcd0b2dd (patch) | |
| tree | bbdea8a8b5cae2e13dca617cd33d78e1454c647d | |
| parent | 3b30ac86592db72435340f92354c47be0d3375fa (diff) | |
| download | rabbitmq-server-git-46474125f27ac435682ca85e4d621697bcd0b2dd.tar.gz | |
Remove some unneeded complexity.
| -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 11d6a79c4c..cc06ae442d 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, |