diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-24 12:50:58 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-24 12:50:58 +0100 |
| commit | b4963dd7aae39e8f8c5306b9d39af6deb7623e63 (patch) | |
| tree | 909a2f25f19825dd3b40e6f28defc76de76597d5 | |
| parent | d99801020fa148777d1a3586eab0ea32e9119ab4 (diff) | |
| download | rabbitmq-server-b4963dd7aae39e8f8c5306b9d39af6deb7623e63.tar.gz | |
Whitespace
| -rw-r--r-- | src/rabbit_mirror_queue_master.erl | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/rabbit_mirror_queue_master.erl b/src/rabbit_mirror_queue_master.erl index 1d2b1676..99de1b18 100644 --- a/src/rabbit_mirror_queue_master.erl +++ b/src/rabbit_mirror_queue_master.erl @@ -254,32 +254,32 @@ requeue(AckTags, MsgPropsFun, State = #state { gm = GM, ok = gm:broadcast(GM, {requeue, MsgPropsFun, MsgIds}), {MsgIds, State #state { backing_queue_state = BQS1 }}. -len(#state { backing_queue = BQ, backing_queue_state = BQS}) -> +len(#state { backing_queue = BQ, backing_queue_state = BQS }) -> BQ:len(BQS). -is_empty(#state { backing_queue = BQ, backing_queue_state = BQS}) -> +is_empty(#state { backing_queue = BQ, backing_queue_state = BQS }) -> BQ:is_empty(BQS). set_ram_duration_target(Target, State = #state { backing_queue = BQ, - backing_queue_state = BQS}) -> + backing_queue_state = BQS }) -> State #state { backing_queue_state = BQ:set_ram_duration_target(Target, BQS) }. -ram_duration(State = #state { backing_queue = BQ, backing_queue_state = BQS}) -> +ram_duration(State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> {Result, BQS1} = BQ:ram_duration(BQS), {Result, State #state { backing_queue_state = BQS1 }}. -needs_timeout(#state { backing_queue = BQ, backing_queue_state = BQS}) -> +needs_timeout(#state { backing_queue = BQ, backing_queue_state = BQS }) -> BQ:needs_timeout(BQS). -timeout(State = #state { backing_queue = BQ, backing_queue_state = BQS}) -> +timeout(State = #state { backing_queue = BQ, backing_queue_state = BQS }) -> State #state { backing_queue_state = BQ:timeout(BQS) }. handle_pre_hibernate(State = #state { backing_queue = BQ, - backing_queue_state = BQS}) -> + backing_queue_state = BQS }) -> State #state { backing_queue_state = BQ:handle_pre_hibernate(BQS) }. -status(#state { backing_queue = BQ, backing_queue_state = BQS}) -> +status(#state { backing_queue = BQ, backing_queue_state = BQS }) -> BQ:status(BQS). invoke(?MODULE, Fun, State) -> |