diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-08-21 13:21:35 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-08-21 13:21:35 +0100 |
| commit | 1e05290def77161bafa0659a632626f2c958bd08 (patch) | |
| tree | 23446903c23c61e3a427f84927d6b86e7c34ad31 | |
| parent | 847153c5a3351fa3f01cd8a906d73adaabfe0aca (diff) | |
| download | rabbitmq-server-1e05290def77161bafa0659a632626f2c958bd08.tar.gz | |
Notify "startup" when we fail over too, that means the federation links will fail over with us.
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index e8011133..b15c9149 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -137,9 +137,11 @@ init_with_backing_queue_state(Q = #amqqueue{exclusive_owner = Owner}, BQ, BQS, senders = Senders, msg_id_to_channel = MTC}, State2 = process_args(State1), - lists:foldl(fun (Delivery, StateN) -> - deliver_or_enqueue(Delivery, true, StateN) - end, State2, Deliveries). + State3 = lists:foldl(fun (Delivery, StateN) -> + deliver_or_enqueue(Delivery, true, StateN) + end, State2, Deliveries), + notify_decorators(startup, [], State3), + State3. init_state(Q) -> State = #q{q = Q, |