Skip to content

Commit 10f3765

Browse files
author
Matthew Sackman
committed
Bumped priority of acks to match that of the unblock and notify_sent calls
1 parent 81dfdbf commit 10f3765

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/rabbit_amqqueue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ requeue(QPid, MsgIds, ChPid) ->
266266
gen_server2:cast(QPid, {requeue, MsgIds, ChPid}).
267267

268268
ack(QPid, Txn, MsgIds, ChPid) ->
269-
gen_server2:cast(QPid, {ack, Txn, MsgIds, ChPid}).
269+
gen_server2:pcast(QPid, 8, {ack, Txn, MsgIds, ChPid}).
270270

271271
commit_all(QPids, Txn) ->
272272
safe_pmap_ok(

0 commit comments

Comments
 (0)