com.atlassian.crowd.manager.cluster.heartbeat

Class CrowdClusterNodeHeartbeatService

java.lang.Object

com.atlassian.beehive.db.AbstractClusterNodeHeartbeatService

com.atlassian.crowd.manager.cluster.heartbeat.CrowdClusterNodeHeartbeatService

All Implemented Interfaces:

com.atlassian.beehive.db.ClusterNodeHeartbeatService, ClusterHeartbeatService, com.atlassian.scheduler.JobRunner

public class CrowdClusterNodeHeartbeatService
extends com.atlassian.beehive.db.AbstractClusterNodeHeartbeatService
implements ClusterHeartbeatService, com.atlassian.scheduler.JobRunner

Field Summary

Fields

Modifier and Type	Field and Description
static long	NODE_LIVENESS_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
CrowdClusterNodeHeartbeatService(ClusterHeartbeatManager clusterNodeHeartBeatDao, com.atlassian.scheduler.SchedulerService localScheduler, com.atlassian.scheduler.SchedulerService clusterwideScheduler, com.atlassian.event.api.EventPublisher eventPublisher, Supplier<Long> timestampSupplier)

Method Summary

Modifier and Type	Method and Description
List<ClusterNode>	getNodeHearbeats()
void	onApplicationStarted(com.atlassian.config.lifecycle.events.ApplicationStartedEvent applicationStartedEvent)
void	onXMLRestore(XMLRestoreFinishedEvent restoreFinishedEvent)
void	registerListener()
com.atlassian.scheduler.JobRunnerResponse	runJob(com.atlassian.scheduler.JobRunnerRequest request)
void	unregisterListener()

Methods inherited from class com.atlassian.beehive.db.AbstractClusterNodeHeartbeatService

findLiveNodes, findLiveNodes, getLastHeartbeatTime, getNodeId, isNodeLive, startHeartbeat

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlassian.beehive.db.ClusterNodeHeartbeatService

findLiveNodes, findLiveNodes, getLastHeartbeatTime, getNodeId, isNodeLive

Field Detail

NODE_LIVENESS_TIMEOUT

public static final long NODE_LIVENESS_TIMEOUT

Constructor Detail

CrowdClusterNodeHeartbeatService

public CrowdClusterNodeHeartbeatService(ClusterHeartbeatManager clusterNodeHeartBeatDao,
                                        com.atlassian.scheduler.SchedulerService localScheduler,
                                        com.atlassian.scheduler.SchedulerService clusterwideScheduler,
                                        com.atlassian.event.api.EventPublisher eventPublisher,
                                        Supplier<Long> timestampSupplier)

Method Detail

registerListener

@PostConstruct
public void registerListener()

unregisterListener

@PreDestroy
public void unregisterListener()

onApplicationStarted

@EventListener
public void onApplicationStarted(com.atlassian.config.lifecycle.events.ApplicationStartedEvent applicationStartedEvent)

onXMLRestore

@EventListener
public void onXMLRestore(XMLRestoreFinishedEvent restoreFinishedEvent)

getNodeHearbeats

public List<ClusterNode> getNodeHearbeats()

Specified by:

getNodeHearbeats in interface ClusterHeartbeatService

Returns:

a list of nodes that have reported a hearbeat recently

runJob

@Nullable
public com.atlassian.scheduler.JobRunnerResponse runJob(com.atlassian.scheduler.JobRunnerRequest request)

Specified by:

runJob in interface com.atlassian.scheduler.JobRunner