diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-26 18:07:52 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-06-26 18:07:52 +0100 |
| commit | eb895b67603a2c0d638fea808477d8901a0aff7c (patch) | |
| tree | ee325f8cd8be002f4e72476d9848358d55e88428 /src | |
| parent | dd38990bd1b1e3f11ba71d85546482367068aa29 (diff) | |
| download | rabbitmq-server-git-eb895b67603a2c0d638fea808477d8901a0aff7c.tar.gz | |
Emit slave creation
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 55d61d4120..4d9a3cbd39 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -101,6 +101,8 @@ init([#amqqueue { name = QueueName } = Q]) -> self(), {rabbit_amqqueue, set_ram_duration_target, [self()]}), {ok, BQ} = application:get_env(backing_queue_module), BQS = bq_init(BQ, Q, false), + rabbit_event:notify(queue_slave_created, + [{name, QueueName}, {pid, self()}, {master_pid, MPid}]), {ok, #state { q = Q, gm = GM, master_pid = MPid, |