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 | e113459faed6e5b43f6a1801411a7b2d4472c20b (patch) | |
| tree | 883d0ed0ce05d31ca2e4ce2c5b1b42e667d5aae2 | |
| parent | 50827e5bf8d35a2cf4c1b9bc77a4b3a69769f29f (diff) | |
| download | rabbitmq-server-git-e113459faed6e5b43f6a1801411a7b2d4472c20b.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 67cd7d76b7..41c2d101cf 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), |