diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-02-28 10:18:31 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-02-28 10:18:31 +0000 |
| commit | cd7ada1e2101c8e15dcfbafa7979d56142dbddbb (patch) | |
| tree | 333ec29cd0fc5176bb2796e3a0e15bcd05276739 /src | |
| parent | 16418a9488e15c4d8ef3bfa9fce69190fb8ec796 (diff) | |
| download | rabbitmq-server-git-cd7ada1e2101c8e15dcfbafa7979d56142dbddbb.tar.gz | |
change priorities in amqqueue
We change all '8' to '7' - this has no effect but brings 'default'
closer to 'bug21673'
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 3f25d72e4f..99fd5d76c0 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -284,7 +284,7 @@ requeue(QPid, MsgIds, ChPid) -> gen_server2:cast(QPid, {requeue, MsgIds, ChPid}). ack(QPid, Txn, MsgIds, ChPid) -> - gen_server2:pcast(QPid, 8, {ack, Txn, MsgIds, ChPid}). + gen_server2:pcast(QPid, 7, {ack, Txn, MsgIds, ChPid}). commit_all(QPids, Txn) -> safe_pmap_ok( @@ -329,10 +329,10 @@ basic_cancel(#amqqueue{pid = QPid}, ChPid, ConsumerTag, OkMsg) -> infinity). notify_sent(QPid, ChPid) -> - gen_server2:pcast(QPid, 8, {notify_sent, ChPid}). + gen_server2:pcast(QPid, 7, {notify_sent, ChPid}). unblock(QPid, ChPid) -> - gen_server2:pcast(QPid, 8, {unblock, ChPid}). + gen_server2:pcast(QPid, 7, {unblock, ChPid}). internal_delete(QueueName) -> rabbit_misc:execute_mnesia_transaction( |