summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@rabbitmq.com>2011-08-18 12:25:02 +0100
committerMatthew Sackman <matthew@rabbitmq.com>2011-08-18 12:25:02 +0100
commit24eda714caf64fb799c5a124c448c19ed015dad2 (patch)
treedf51a9e9eddae88baa6cead50c26022f7f3000b2
parentd2279893cfb93606cd39820e6e39c86c0da57ee4 (diff)
downloadrabbitmq-server-24eda714caf64fb799c5a124c448c19ed015dad2.tar.gz
Allow basic_consume and basic_cancel to match the priority of ack and co
-rw-r--r--src/rabbit_amqqueue_process.erl10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index 11a95a62..30ab0457 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -817,10 +817,12 @@ emit_consumer_deleted(ChPid, ConsumerTag) ->
prioritise_call(Msg, _From, _State) ->
case Msg of
- info -> 9;
- {info, _Items} -> 9;
- consumers -> 9;
- _ -> 0
+ info -> 9;
+ {info, _Items} -> 9;
+ consumers -> 9;
+ {basic_consume, _, _, _, _, _, _} -> 7;
+ {basic_cancel, _, _, _} -> 7;
+ _ -> 0
end.
prioritise_cast(Msg, _State) ->