diff options
author | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-06 04:43:14 +0000 |
---|---|---|
committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-01-06 04:43:14 +0000 |
commit | 0b7c1a6c6ee008f836efb7d40a48a1df9d850fac (patch) | |
tree | e86ac8799bd60557b2f7ac5f1ffa4024dc4155bc | |
parent | a045f82f44f70dddc74f025812300ed104688f5b (diff) | |
download | rabbitmq-server-0b7c1a6c6ee008f836efb7d40a48a1df9d850fac.tar.gz |
restrict previous optimisation, for better workingness
-rw-r--r-- | src/rabbit_channel.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 37354f93..aaa463f1 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1327,7 +1327,9 @@ notify_limiter(Limiter, Acked) -> end end. -deliver_to_queues({#delivery{message = #basic_message{exchange_name = XName}}, +deliver_to_queues({#delivery{message = #basic_message{exchange_name = XName}, + msg_seq_no = undefined, + mandatory = false}, []}, State) -> %% optimisation ?INCR_STATS([{exchange_stats, XName, 1}], publish, State), State; |