diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-06 00:44:35 +0000 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-06 00:44:35 +0000 |
commit | f2474ad8809cd83b71741eef718138d2479b745e (patch) | |
tree | 2f90548767875c6c6a56aa9df7dbd8e83f3ff3f0 | |
parent | 115369202c1a49b3030e091a545c775149b818da (diff) | |
download | rabbitmq-server-f2474ad8809cd83b71741eef718138d2479b745e.tar.gz |
optimise "route to no queues" path
-rw-r--r-- | src/rabbit_channel.erl | 4 |
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}, |