com.atlassian.bamboo.beehive

Class BambooClusterNodeHeartBeatRawJdbcDao

java.lang.Object

com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

com.atlassian.bamboo.beehive.BambooClusterNodeHeartBeatRawJdbcDao

All Implemented Interfaces:

ClusterNodeHeartbeatBootstrapDao, com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao, EventListener, javax.servlet.ServletContextListener

public class BambooClusterNodeHeartBeatRawJdbcDao
extends AbstractBambooRawJdbcDao
implements ClusterNodeHeartbeatBootstrapDao

Field Summary

Fields

Modifier and Type	Field and Description
static int	NODE_ID_MAX_LENGTH
static int	NODE_NAME_MAX_LENGTH

Fields inherited from class com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

dbmsBean, hibernateConfig, postBoostrap

Constructor Summary

Constructors

Constructor and Description
BambooClusterNodeHeartBeatRawJdbcDao()

Method Summary

Modifier and Type	Method and Description
void	ensureNodeHeartbeatTableExists() Creates heartbeat table if required.
List<BambooNodeStatus>	findAll() Get all heartbeats.
Collection<String>	findNodesWithHeartbeatsAfter(long time)
Long	getLastHeartbeatTime(String nodeId)
String	getNodeId()
void	writeHeartBeat(long time)

Methods inherited from class com.atlassian.bamboo.beehive.AbstractBambooRawJdbcDao

contextDestroyed, contextInitialized, ensureClusterTableExists, supplierWithConnection, withDatabaseConnection

Methods inherited from class java.lang.Object

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

Field Detail

NODE_ID_MAX_LENGTH

public static final int NODE_ID_MAX_LENGTH

See Also:

Constant Field Values

NODE_NAME_MAX_LENGTH

public static final int NODE_NAME_MAX_LENGTH

See Also:

Constant Field Values

Constructor Detail

BambooClusterNodeHeartBeatRawJdbcDao

public BambooClusterNodeHeartBeatRawJdbcDao()

Method Detail

getNodeId

@NotNull
public String getNodeId()

Specified by:

getNodeId in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao

writeHeartBeat

public void writeHeartBeat(long time)

Specified by:

writeHeartBeat in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao

getLastHeartbeatTime

@Nullable
public Long getLastHeartbeatTime(@NotNull
                                           String nodeId)

Specified by:

getLastHeartbeatTime in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao

findNodesWithHeartbeatsAfter

@NotNull
public Collection<String> findNodesWithHeartbeatsAfter(long time)

Specified by:

findNodesWithHeartbeatsAfter in interface com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao

findAll

public List<BambooNodeStatus> findAll()

Description copied from interface: ClusterNodeHeartbeatBootstrapDao

Get all heartbeats.

Specified by:

findAll in interface ClusterNodeHeartbeatBootstrapDao

ensureNodeHeartbeatTableExists

public void ensureNodeHeartbeatTableExists()

Description copied from interface: ClusterNodeHeartbeatBootstrapDao

Creates heartbeat table if required.

Specified by:

ensureNodeHeartbeatTableExists in interface ClusterNodeHeartbeatBootstrapDao