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 | c40b8f5e55a2a5cc24017413314f08277401fe56 (patch) | |
| tree | c4966165a1ed77ec32a2d4c77d893546ad259cdd | |
| parent | 30f0eade6ede81efde4d23d715fd0f83f19abe03 (diff) | |
| download | rabbitmq-server-bug22223.tar.gz | |
Bumped priority of acks to match that of the unblock and notify_sent callsbug22223
| -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 d728ef6a..515dbf68 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( |