diff options
| author | Matthias Radestock <matthias@lshift.net> | 2010-01-19 21:40:42 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2010-01-19 21:40:42 +0000 |
| commit | 85b9f37c52e7d5b79cc722c03f423600089777c8 (patch) | |
| tree | 2b23768859ad9305d628bb69bb8c3b19d9f04101 | |
| parent | f9524331f4796f3288195085d6dadf83aa7d9ce3 (diff) | |
| parent | 10f37652e57e2e9272816022cd889b3b491df99d (diff) | |
| download | rabbitmq-server-git-85b9f37c52e7d5b79cc722c03f423600089777c8.tar.gz | |
merge bug22223 into v1_7
| -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( |