diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2012-01-17 20:08:42 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2012-01-17 20:08:42 +0000 |
| commit | 13d710e3cfabbc2030127d7242205a0ee41aad55 (patch) | |
| tree | 7d612935acee0f313c7a71837d011fe1a501b494 | |
| parent | 021e6a2ea0bf4369bb7afb3b165dfd11909f7a6c (diff) | |
| parent | c1fc0fa04e88388acb7f066f1bde4061e9c17d3d (diff) | |
| download | rabbitmq-server-13d710e3cfabbc2030127d7242205a0ee41aad55.tar.gz | |
merge heads
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 06c5beac..2cdc7637 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -253,6 +253,10 @@ handle_info({'DOWN', _MonitorRef, process, ChPid, _Reason}, State) -> handle_info({'EXIT', _Pid, Reason}, State) -> {stop, Reason, State}; +handle_info({bump_credit, Msg}, State) -> + credit_flow:handle_bump_msg(Msg), + noreply(State); + handle_info(Msg, State) -> {stop, {unexpected_info, Msg}, State}. |