diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-01-17 17:27:15 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-01-17 17:27:15 +0000 |
| commit | efc76de61ce776ed0fa5f1c5f6fbb5f7dbae9dc9 (patch) | |
| tree | 62a0132b07710aef32a1cf4606fe41042fdb9e4b /src | |
| parent | c9eb26930121f210a4eba76759a5866656e55e6b (diff) | |
| download | rabbitmq-server-git-efc76de61ce776ed0fa5f1c5f6fbb5f7dbae9dc9.tar.gz | |
Flow control: queue slave -> msg_store.
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}. |