diff options
| author | Matthew Sackman <matthew@lshift.net> | 2010-01-18 13:44:24 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2010-01-18 13:44:24 +0000 |
| commit | 10f37652e57e2e9272816022cd889b3b491df99d (patch) | |
| tree | c4966165a1ed77ec32a2d4c77d893546ad259cdd | |
| parent | 81dfdbfb14e974d281648f03f1da26f4220cd489 (diff) | |
| download | rabbitmq-server-git-10f37652e57e2e9272816022cd889b3b491df99d.tar.gz | |
Bumped priority of acks to match that of the unblock and notify_sent calls
| -rw-r--r-- | src/rabbit_amqqueue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index d728ef6a76..515dbf6823 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -266,7 +266,7 @@ requeue(QPid, MsgIds, ChPid) -> gen_server2:cast(QPid, {requeue, MsgIds, ChPid}). ack(QPid, Txn, MsgIds, ChPid) -> - gen_server2:cast(QPid, {ack, Txn, MsgIds, ChPid}). + gen_server2:pcast(QPid, 8, {ack, Txn, MsgIds, ChPid}). commit_all(QPids, Txn) -> safe_pmap_ok( |