summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-06 04:43:14 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-06 04:43:14 +0000
commit0b7c1a6c6ee008f836efb7d40a48a1df9d850fac (patch)
treee86ac8799bd60557b2f7ac5f1ffa4024dc4155bc
parenta045f82f44f70dddc74f025812300ed104688f5b (diff)
downloadrabbitmq-server-0b7c1a6c6ee008f836efb7d40a48a1df9d850fac.tar.gz
restrict previous optimisation, for better workingness
-rw-r--r--src/rabbit_channel.erl4
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;