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 | 7f12ebe6bea5e2c996420870037e312a3a1cff2e (patch) | |
| tree | 2f90548767875c6c6a56aa9df7dbd8e83f3ff3f0 /src | |
| parent | ed83bfbfc488aca848f5e554e33a7af469a0d981 (diff) | |
| download | rabbitmq-server-git-7f12ebe6bea5e2c996420870037e312a3a1cff2e.tar.gz | |
optimise "route to no queues" path
Diffstat (limited to 'src')
| -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 11a117ee1c..b9f8d1bb39 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}, |