summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2012-06-19 14:21:39 +0100
committerSimon MacMullen <simon@rabbitmq.com>2012-06-19 14:21:39 +0100
commit302abe3ea39e654a32af30266fad483c7845915b (patch)
tree7e05163133629699532f9aca30d887fd98dbc24d
parent016bd08ec5864bf56ba2e54bde41a906ffcf3b2c (diff)
downloadrabbitmq-server-302abe3ea39e654a32af30266fad483c7845915b.tar.gz
Backport 6871aae71b8b (Merge of bug24966; Prioritising deliveries leads to publish starvation)
-rw-r--r--src/rabbit_amqqueue_process.erl6
1 files changed, 0 insertions, 6 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index 5701efeb..f2833c26 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -984,8 +984,6 @@ prioritise_call(Msg, _From, _State) ->
info -> 9;
{info, _Items} -> 9;
consumers -> 9;
- {basic_consume, _, _, _, _, _, _} -> 7;
- {basic_cancel, _, _, _} -> 7;
stat -> 7;
_ -> 0
end.
@@ -995,10 +993,6 @@ prioritise_cast(Msg, _State) ->
delete_immediately -> 8;
{set_ram_duration_target, _Duration} -> 8;
{set_maximum_since_use, _Age} -> 8;
- {ack, _AckTags, _ChPid} -> 7;
- {reject, _AckTags, _Requeue, _ChPid} -> 7;
- {notify_sent, _ChPid, _Credit} -> 7;
- {unblock, _ChPid} -> 7;
{run_backing_queue, _Mod, _Fun} -> 6;
_ -> 0
end.