summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2010-10-21 12:58:29 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2010-10-21 12:58:29 +0100
commit223169c50fd88e97695a04ea1559b4682389b1d9 (patch)
treec2e747465d693ece541d46e2576278c5a370c823
parentb094e9fbf67da0b5cd224b0b70d4ba91140010c3 (diff)
downloadrabbitmq-server-223169c50fd88e97695a04ea1559b4682389b1d9.tar.gz
Whitespace
-rw-r--r--src/rabbit_amqqueue_process.erl5
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);