diff options
author | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-21 12:58:29 +0100 |
---|---|---|
committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-10-21 12:58:29 +0100 |
commit | 223169c50fd88e97695a04ea1559b4682389b1d9 (patch) | |
tree | c2e747465d693ece541d46e2576278c5a370c823 | |
parent | b094e9fbf67da0b5cd224b0b70d4ba91140010c3 (diff) | |
download | rabbitmq-server-223169c50fd88e97695a04ea1559b4682389b1d9.tar.gz |
Whitespace
-rw-r--r-- | src/rabbit_amqqueue_process.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 397fe31b..a2fab54c 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -602,13 +602,13 @@ drop_expired_messages(State = #q{backing_queue_state = BQS, fun (#message_properties{expiry = Expiry}) -> Now > Expiry end, BQS), - ensure_ttl_timer(State #q{backing_queue_state = BQS1}). + ensure_ttl_timer(State#q{backing_queue_state = BQS1}). ensure_ttl_timer(State = #q{backing_queue = BQ, backing_queue_state = BQS, ttl = TTL, ttl_timer_ref = undefined}) - when TTL =/= undefined-> + when TTL =/= undefined -> case BQ:is_empty(BQS) of true -> State; @@ -748,7 +748,6 @@ handle_call({deliver_immediately, Txn, Message, ChPid}, _From, State) -> %% just all ready-to-consume queues get the message, with unready %% queues discarding the message? %% - {Delivered, NewState} = attempt_delivery(Txn, ChPid, Message, State), reply(Delivered, NewState); |