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 | c1fc0fa04e88388acb7f066f1bde4061e9c17d3d (patch) | |
| tree | 62a0132b07710aef32a1cf4606fe41042fdb9e4b /src/rabbit_mirror_queue_slave.erl | |
| parent | b74f69d1472551b78c345982cdce6cb53a7c559e (diff) | |
| download | rabbitmq-server-c1fc0fa04e88388acb7f066f1bde4061e9c17d3d.tar.gz | |
Flow control: queue slave -> msg_store.
Diffstat (limited to 'src/rabbit_mirror_queue_slave.erl')
| -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}. |