org.apache.ambari.server.state.services

Class CachedAlertFlushService

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

org.apache.ambari.server.state.services.CachedAlertFlushService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class CachedAlertFlushService
extends com.google.common.util.concurrent.AbstractScheduledService

The CachedAlertFlushService is used to periodically flush cached alert data to the database. This service is controlled by Configuration.isAlertCacheEnabled() and Configuration.getAlertCacheFlushInterval().

Nested Class Summary

Nested classes/interfaces inherited from class com.google.common.util.concurrent.AbstractScheduledService

com.google.common.util.concurrent.AbstractScheduledService.CustomScheduler, com.google.common.util.concurrent.AbstractScheduledService.Scheduler

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
CachedAlertFlushService()

Method Summary

Modifier and Type	Method and Description
protected void	runOneIteration() Flushes cached alerts to the database.
protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler	scheduler()
protected void	startUp() Invokes #stop() if not enabled.

Methods inherited from class com.google.common.util.concurrent.AbstractScheduledService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, shutDown, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CachedAlertFlushService

public CachedAlertFlushService()

Method Detail

scheduler

protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler scheduler()

Specified by:

scheduler in class com.google.common.util.concurrent.AbstractScheduledService

startUp

protected void startUp()
                throws Exception

Invokes #stop() if not enabled.

Overrides:

startUp in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception

runOneIteration

protected void runOneIteration()
                        throws Exception

Flushes cached alerts to the database.

Specified by:

runOneIteration in class com.google.common.util.concurrent.AbstractScheduledService

Throws:

Exception