com.atlassian.jira.cluster.lock

Class StartableClusterNodeHeartbeatService

java.lang.Object

com.atlassian.jira.cluster.lock.StartableClusterNodeHeartbeatService

All Implemented Interfaces:

com.atlassian.beehive.db.ClusterNodeHeartbeatService, Startable

public class StartableClusterNodeHeartbeatService
extends Object
implements com.atlassian.beehive.db.ClusterNodeHeartbeatService, Startable

JIRA implementation of ClusterNodeHeartbeatService

Since:

6.3

Constructor Summary

Constructors

Constructor and Description
StartableClusterNodeHeartbeatService(com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao clusterNodeHeartBeatDao, HeartbeatScheduledExecutorFactory scheduledExecutorFactory, HeartbeatJob heartbeatJob, com.atlassian.core.util.Clock clock, HeartbeatSettings settings)

Method Summary

Modifier and Type	Method and Description
Collection<String>	findLiveNodes()
Collection<String>	findLiveNodes(long threshold)
Long	getLastHeartbeatTime(String nodeId)
String	getNodeId()
boolean	isNodeLive(String nodeId)
void	start() This method will be called after the plugin system is fully initialised and all components added to the dependency injection framework.

Methods inherited from class java.lang.Object

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

Constructor Detail

StartableClusterNodeHeartbeatService

public StartableClusterNodeHeartbeatService(com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao clusterNodeHeartBeatDao,
                                            HeartbeatScheduledExecutorFactory scheduledExecutorFactory,
                                            HeartbeatJob heartbeatJob,
                                            com.atlassian.core.util.Clock clock,
                                            HeartbeatSettings settings)

Method Detail

start

public void start()
           throws Exception

Description copied from interface: Startable

This method will be called after the plugin system is fully initialised and all components added to the dependency injection framework.

Specified by:

start in interface Startable

Throws:

Exception - Allows implementations to throw an Exception.

getNodeId

@Nonnull
public String getNodeId()

Specified by:

getNodeId in interface com.atlassian.beehive.db.ClusterNodeHeartbeatService

isNodeLive

public boolean isNodeLive(@Nonnull
                          String nodeId)

Specified by:

isNodeLive in interface com.atlassian.beehive.db.ClusterNodeHeartbeatService

getLastHeartbeatTime

@Nullable
public Long getLastHeartbeatTime(@Nonnull
                                           String nodeId)

Specified by:

getLastHeartbeatTime in interface com.atlassian.beehive.db.ClusterNodeHeartbeatService

findLiveNodes

@Nonnull
public Collection<String> findLiveNodes()

Specified by:

findLiveNodes in interface com.atlassian.beehive.db.ClusterNodeHeartbeatService

findLiveNodes

@Nonnull
public Collection<String> findLiveNodes(long threshold)

Specified by:

findLiveNodes in interface com.atlassian.beehive.db.ClusterNodeHeartbeatService