diff options
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, |