diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-11-20 10:51:26 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-11-20 10:51:26 +0000 |
| commit | 974789eb3cadffe083b7abba13e7f469714e3f4c (patch) | |
| tree | 69d19529f8c793bd3b65b9003069a6777f05b15e | |
| parent | cd19a0961f775abe1b189bfddd020ac2f7288605 (diff) | |
| download | rabbitmq-server-git-974789eb3cadffe083b7abba13e7f469714e3f4c.tar.gz | |
Don't prioritise 'reject', it could lead to observable reordering.
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index fc63f097fc..cbbafc3e91 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1114,7 +1114,6 @@ prioritise_cast(Msg, _Len, State) -> {set_maximum_since_use, _Age} -> 8; {run_backing_queue, _Mod, _Fun} -> 6; {ack, _AckTags, _ChPid} -> consumer_bias(State); - {reject, _AckTags, _Requeue, _ChPid} -> consumer_bias(State); {notify_sent, _ChPid, _Credit} -> consumer_bias(State); {resume, _ChPid} -> consumer_bias(State); _ -> 0 |