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
commit18603e0edaa3c889197b27a5eb16cf5a97499e54 (patch)
treee86ac8799bd60557b2f7ac5f1ffa4024dc4155bc
parent2aa7309902c5c117ac06a16f33ea466e66ffd1b5 (diff)
downloadrabbitmq-server-git-18603e0edaa3c889197b27a5eb16cf5a97499e54.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 37354f93b3..aaa463f164 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;