summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2012-01-13 16:06:54 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2012-01-13 16:06:54 +0000
commit960580487c396598b5a40ba1a314968d466631e8 (patch)
tree95368f2b22e2241e42282a1de2dad61a55824e1a
parent94769c9830e32cca3889488e122a0f1f99e12b78 (diff)
downloadrabbitmq-server-960580487c396598b5a40ba1a314968d466631e8.tar.gz
cosmetic(ish)
-rw-r--r--src/rabbit_channel.erl10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index db9ff7a0..b478d9f9 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -1345,15 +1345,15 @@ notify_limiter(Limiter, Acked) ->
deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{
exchange_name = XName},
- mandatory = Mandatory,
- immediate = Immediate,
+ mandatory = Mandatory,
+ immediate = Immediate,
msg_seq_no = MsgSeqNo},
QNames}, State) ->
{RoutingRes, DeliveredQPids} = rabbit_router:deliver(QNames, Delivery),
State1 = lists:foldl(fun monitor_queue/2, State, DeliveredQPids),
- case Mandatory orelse Immediate of
- false -> [rabbit_flow:send(QPid) || QPid <- DeliveredQPids];
- _ -> ok
+ case {Mandatory, Immediate} of
+ {false, false} -> [rabbit_flow:send(QPid) || QPid <- DeliveredQPids];
+ _ -> ok
end,
State2 = process_routing_result(RoutingRes, DeliveredQPids,
XName, MsgSeqNo, Message, State1),