diff options
| -rw-r--r-- | src/rabbit_reader.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/rabbit_reader.erl b/src/rabbit_reader.erl index 11ee686e79..7a67b70c14 100644 --- a/src/rabbit_reader.erl +++ b/src/rabbit_reader.erl @@ -331,7 +331,10 @@ handle_other({conserve_resources, Source, Conserve}, Throttle1 = Throttle#throttle{alarmed_by = CR1}, State1 = control_throttle(State#v1{throttle = Throttle1}), case {CS, State1#v1.connection_state, (CR =/= []), (CR1 =:= [])} of - {blocked, running, true, true} -> + {blocked, running, _, _} -> + send_unblocked(State1), + ok; + {blocked, blocked, true, true} -> send_unblocked(State1), ok; {_, _, _, _} -> |