diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-26 20:49:17 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-26 20:49:17 +0100 |
| commit | 479792104a66677c5fe4ae65b8b9cc53c1ed2b18 (patch) | |
| tree | 39b484e980511f4a43476c98e12d9b5c9d8eed15 /src | |
| parent | 4d71d306cfaf231f5a4714ed8df4f499579bcff9 (diff) | |
| download | rabbitmq-server-git-479792104a66677c5fe4ae65b8b9cc53c1ed2b18.tar.gz | |
Notify the world when we become synchronised
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index f4c950a9e7..a4a40a8c94 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -893,6 +893,7 @@ maybe_store_ack(true, MsgId, AckTag, State = #state { msg_id_ack = MA, %% We intentionally leave out the head where a slave becomes %% unsynchronised: we assert that can never happen. set_synchronised(true, State = #state { synchronised = false }) -> + rabbit_event:notify(queue_slave_synchronised, [{pid, self()}]), State #state { synchronised = true }; set_synchronised(true, State) -> State; |