diff options
author | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-18 12:25:02 +0100 |
---|---|---|
committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-18 12:25:02 +0100 |
commit | 24eda714caf64fb799c5a124c448c19ed015dad2 (patch) | |
tree | df51a9e9eddae88baa6cead50c26022f7f3000b2 | |
parent | d2279893cfb93606cd39820e6e39c86c0da57ee4 (diff) | |
download | rabbitmq-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.erl | 10 |
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) -> |