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 | dc717d13bdaff8ee0b1e78b33596491f43fe1b30 (patch) | |
| tree | 69d19529f8c793bd3b65b9003069a6777f05b15e | |
| parent | b0b1b7d369b292f9c85b39626619147b556b7f66 (diff) | |
| download | rabbitmq-server-dc717d13bdaff8ee0b1e78b33596491f43fe1b30.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 fc63f097..cbbafc3e 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 |