diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-25 22:07:40 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-25 22:07:40 +0100 |
| commit | c6b0630ca1249f1a2bf4210feec2c788550ee2a4 (patch) | |
| tree | a0b2cd6512416512b73e928d51aac05b56b2a21a | |
| parent | c2698a744b47e24b8ff7fb19b8d574e73792b370 (diff) | |
| download | rabbitmq-server-bug24221.tar.gz | |
remember when we've refused a queue's can_send due to being blockedbug24221
so that we can tell the queue when we get unblocked
| -rw-r--r-- | src/rabbit_limiter.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 1b72dd76..e79583fa 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -120,9 +120,9 @@ init([ChPid, UnackedMsgCount]) -> prioritise_call(get_limit, _From, _State) -> 9; prioritise_call(_Msg, _From, _State) -> 0. -handle_call({can_send, _QPid, _AckRequired}, _From, +handle_call({can_send, QPid, _AckRequired}, _From, State = #lim{blocked = true}) -> - {reply, false, State}; + {reply, false, limit_queue(QPid, State)}; handle_call({can_send, QPid, AckRequired}, _From, State = #lim{volume = Volume}) -> case limit_reached(State) of |