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 | afa6d34a55ae93b61e2584dbf2f0d2ee1b38ab96 (patch) | |
| tree | 7d612935acee0f313c7a71837d011fe1a501b494 /src | |
| parent | bee2e6d7e38faebb2810b29084d944d7f5f82d2e (diff) | |
| parent | efc76de61ce776ed0fa5f1c5f6fbb5f7dbae9dc9 (diff) | |
| download | rabbitmq-server-git-afa6d34a55ae93b61e2584dbf2f0d2ee1b38ab96.tar.gz | |
merge heads
Diffstat (limited to 'src')
| -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 06c5beac01..2cdc763723 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}. |