diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-07-26 13:16:07 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-07-26 13:16:07 +0100 |
| commit | 5006a8e57a70fb703bf9818a5f6243c75a54a326 (patch) | |
| tree | 3166c6c4b00cfc95f841aff6c2ff251019ddbecc | |
| parent | 4322cc5fa45c0726db7811726713fab62e0e1a99 (diff) | |
| download | rabbitmq-server-5006a8e57a70fb703bf9818a5f6243c75a54a326.tar.gz | |
Tweak priorities a bit.
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_channel.erl | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 0489f139..a3a912b9 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -315,7 +315,7 @@ consumers_all(VHostPath) -> stat(#amqqueue{pid = QPid}) -> delegate_call(QPid, stat, infinity). emit_stats(#amqqueue{pid = QPid}) -> - delegate_pcast(QPid, 8, emit_stats). + delegate_pcast(QPid, 7, emit_stats). delete(#amqqueue{ pid = QPid }, IfUnused, IfEmpty) -> delegate_call(QPid, {delete, IfUnused, IfEmpty}, infinity). @@ -411,7 +411,7 @@ internal_delete(QueueName) -> end. maybe_run_queue_via_backing_queue(QPid, Fun) -> - gen_server2:pcall(QPid, 7, {maybe_run_queue_via_backing_queue, Fun}, + gen_server2:pcall(QPid, 6, {maybe_run_queue_via_backing_queue, Fun}, infinity). update_ram_duration(QPid) -> diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index d18329ff..c16f9026 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -158,7 +158,7 @@ info_all(Items) -> rabbit_misc:filter_exit_map(fun (C) -> info(C, Items) end, list()). emit_stats(Pid) -> - gen_server2:pcast(Pid, 8, emit_stats). + gen_server2:pcast(Pid, 7, emit_stats). %%--------------------------------------------------------------------------- |