diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-08-18 15:32:58 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-08-18 15:32:58 +0100 |
| commit | 6bff5992e8914134810509da1b248015efe03e3b (patch) | |
| tree | c1682bfe7bb28edbf5e7d2a51ff4d995df40abb8 | |
| parent | d2582b551f68d95dfc07b2f29bae95cb0a66770f (diff) | |
| parent | 592cd98da49e3b5699fa2dd491a7cbabf86fae5f (diff) | |
| download | rabbitmq-server-git-6bff5992e8914134810509da1b248015efe03e3b.tar.gz | |
merge bug24194 into default
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 11a95a6221..e5038efe39 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -817,10 +817,13 @@ 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; + stat -> 7; + _ -> 0 end. prioritise_cast(Msg, _State) -> |