diff options
| author | Michael Klishin <michael@rabbitmq.com> | 2014-02-19 20:28:20 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@rabbitmq.com> | 2014-02-19 20:28:20 +0400 |
| commit | 3667a3b9a01db7ce1088bb6adfe18137b5de13c5 (patch) | |
| tree | 8689dca3601097112c66162e1874dac412745361 | |
| parent | 1b3ae5554b91e5977a542c4679f916e5ac8c6df4 (diff) | |
| download | rabbitmq-server-git-3667a3b9a01db7ce1088bb6adfe18137b5de13c5.tar.gz | |
Send connection.unblocked when connection is no longer blocked or all alarms clear
| -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; {_, _, _, _} -> |