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 | bb5b1540d9680eb39d5d1cd0f668b8c1c6708b01 (patch) | |
| tree | 23446903c23c61e3a427f84927d6b86e7c34ad31 /src | |
| parent | c2f2ebdfd32793516cf2a7c199f7aa2a3f5fd750 (diff) | |
| download | rabbitmq-server-git-bb5b1540d9680eb39d5d1cd0f668b8c1c6708b01.tar.gz | |
Notify "startup" when we fail over too, that means the federation links will fail over with us.
Diffstat (limited to 'src')
| -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 e80111330f..b15c914923 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, |