org.apache.ambari.server.state.services

Class AmbariServerAlertService

java.lang.Object

com.google.common.util.concurrent.AbstractScheduledService

org.apache.ambari.server.state.services.AmbariServerAlertService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

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

The AmbariServerAlertService is used to manage the dynamically loaded AlertRunnables which perform server-side alert checks. The AlertRunnables are scheduled using a ScheduledExecutorService with a fixed thread pool size.

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
AmbariServerAlertService() Constructor.

Method Summary

Modifier and Type	Method and Description
void	initExecutor(int alertServiceCorePoolSize)
protected void	runOneIteration() Compares all known RootComponent.AMBARI_SERVER alerts with those that are scheduled.
protected com.google.common.util.concurrent.AbstractScheduledService.Scheduler	scheduler()
protected void	startUp() Loads all of the definitions with SERVER source type and schedules the ones that are 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

AmbariServerAlertService

public AmbariServerAlertService()

Constructor.

Method Detail

initExecutor

@Inject
public void initExecutor(int alertServiceCorePoolSize)

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

Loads all of the definitions with SERVER source type and schedules the ones that are enabled.

Overrides:

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

Throws:

Exception

runOneIteration

protected void runOneIteration()
                        throws Exception

Compares all known RootComponent.AMBARI_SERVER alerts with those that are scheduled. If any are not scheduled or have their intervals changed, then reschedule those.

Specified by:

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

Throws:

Exception