io.micronaut.health

Class HeartbeatTask

java.lang.Object

io.micronaut.health.HeartbeatTask

All Implemented Interfaces:

ApplicationEventListener<ServiceStartedEvent>, EventListener

@Singleton
 @HeartbeatEnabled
public class HeartbeatTask
extends Object
implements ApplicationEventListener<ServiceStartedEvent>

A scheduled task that sends a periodic heartbeat whilst the server is active.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
HeartbeatTask(ApplicationEventPublisher eventPublisher, HeartbeatConfiguration configuration, CurrentHealthStatus currentHealthStatus)

Method Summary

Modifier and Type	Method and Description
void	onApplicationEvent(ServiceStartedEvent event) Handle an application event.
void	pulsate() Publish the heartbeat event with current health status.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.context.event.ApplicationEventListener

supports

Constructor Detail

HeartbeatTask

public HeartbeatTask(ApplicationEventPublisher eventPublisher,
                     HeartbeatConfiguration configuration,
                     CurrentHealthStatus currentHealthStatus)

Parameters:

eventPublisher - To publish the events related to heartbeat

configuration - The configurations for heartbeat

currentHealthStatus - The current status of health indicator

Method Detail

pulsate

@Scheduled(fixedDelay="${micronaut.heartbeat.interval:15s}",
           initialDelay="${micronaut.heartbeat.initial-delay:5s}")
public void pulsate()

Publish the heartbeat event with current health status.

onApplicationEvent

public void onApplicationEvent(ServiceStartedEvent event)

Description copied from interface: ApplicationEventListener

Handle an application event.

Specified by:

onApplicationEvent in interface ApplicationEventListener<ServiceStartedEvent>

Parameters:

event - the event to respond to