lib/flapjack/processor.rb in flapjack-2.0.0b1 vs lib/flapjack/processor.rb in flapjack-2.0.0rc1

- old
+ new

@@ -41,10 +41,15 @@ @repeat_failure_delay = @config['repeat_failure_delay'] if !@repeat_failure_delay.is_a?(Integer) || (@repeat_failure_delay < 0) @repeat_failure_delay = nil end + @initial_recovery_delay = @config['initial_recovery_delay'] + if !@initial_recovery_delay.is_a?(Integer) || (@initial_recovery_delay < 0) + @initial_recovery_delay = nil + end + @notifier_queue = Flapjack::RecordQueue.new(@config['notifier_queue'] || 'notifications', Flapjack::Data::Notification) @archive_events = @config['archive_events'] || false @events_archive_maxage = @config['events_archive_maxage'] @@ -263,12 +268,18 @@ repeat_fail_delay = (event_condition.nil? ? nil : event.repeat_failure_delay) || check.repeat_failure_delay || @repeat_failure_delay || Flapjack::DEFAULT_REPEAT_FAILURE_DELAY + init_recov_delay = (event_condition.nil? ? nil : event.initial_recovery_delay) || + check.initial_recovery_delay || + @initial_recovery_delay || + Flapjack::DEFAULT_INITIAL_RECOVERY_DELAY + filter_opts = { :initial_failure_delay => init_fail_delay, :repeat_failure_delay => repeat_fail_delay, + :initial_recovery_delay => init_recov_delay, :old_state => old_state, :new_state => new_state, :timestamp => timestamp, :duration => event.duration } # acks only go into latest_notifications