summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-06 00:44:35 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-06 00:44:35 +0000
commitf2474ad8809cd83b71741eef718138d2479b745e (patch)
tree2f90548767875c6c6a56aa9df7dbd8e83f3ff3f0
parent115369202c1a49b3030e091a545c775149b818da (diff)
downloadrabbitmq-server-f2474ad8809cd83b71741eef718138d2479b745e.tar.gz
optimise "route to no queues" path
-rw-r--r--src/rabbit_channel.erl4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 11a117ee..b9f8d1bb 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -1327,6 +1327,10 @@ notify_limiter(Limiter, Acked) ->
end
end.
+deliver_to_queues({#delivery{message = #basic_message{exchange_name = XName}},
+ []}, State) -> %% optimisation
+ ?INCR_STATS([{exchange_stats, XName, 1}], publish, State),
+ State;
deliver_to_queues({Delivery = #delivery{message = Message = #basic_message{
exchange_name = XName},
msg_seq_no = MsgSeqNo},