diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-26 18:17:00 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-26 18:17:00 +0100 |
| commit | a07a3fa48f73cb86c2afd246bbeec35177a455c5 (patch) | |
| tree | 50931b0fe7f8062e0693c8d5b59b3caa249811c7 /src/rabbit_mirror_queue_slave.erl | |
| parent | d1cc2873044d00c294cabbe15284885dbfaef94b (diff) | |
| download | rabbitmq-server-a07a3fa48f73cb86c2afd246bbeec35177a455c5.tar.gz | |
Slaves request length when they join.
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 81e83301..8a365e6a 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -103,6 +103,7 @@ init([#amqqueue { name = QueueName } = Q]) -> BQS = bq_init(BQ, Q, false), rabbit_event:notify(queue_slave_created, [{name, QueueName}, {pid, self()}, {master_pid, MPid}]), + ok = gm:broadcast(GM, request_length), {ok, #state { q = Q, gm = GM, master_pid = MPid, @@ -305,6 +306,9 @@ members_changed([SPid], _Births, Deaths) -> handle_msg([_SPid], _From, heartbeat) -> ok; +handle_msg([_SPid], _From, request_length) -> + %% This is only of value to the master + ok; handle_msg([_SPid], _From, {ensure_monitoring, _Pid}) -> %% This is only of value to the master ok; |