diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-06-10 13:56:33 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-06-10 13:56:33 +0100 |
| commit | c807a4f6642b10c7d2f57f58b1502706d538eafa (patch) | |
| tree | 883d0ed0ce05d31ca2e4ce2c5b1b42e667d5aae2 | |
| parent | dd42e71e166de36fb373f4528bf66f35cac37f2a (diff) | |
| download | rabbitmq-server-c807a4f6642b10c7d2f57f58b1502706d538eafa.tar.gz | |
fix off-by-one error
not that it really matters much
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 67cd7d76..41c2d101 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -148,7 +148,7 @@ all_ch_record() -> [C || {{ch, _}, C} <- get()]. is_ch_blocked(#cr{unsent_message_count = Count, is_limit_active = Limited}) -> - Limited orelse Count > ?UNSENT_MESSAGE_LIMIT. + Limited orelse Count >= ?UNSENT_MESSAGE_LIMIT. ch_record_state_transition(OldCR, NewCR) -> BlockedOld = is_ch_blocked(OldCR), |