Package com.atlassian.crowd.manager.cluster.heartbeat

Class CrowdClusterHeartbeatManager

java.lang.Object

com.atlassian.crowd.manager.cluster.heartbeat.CrowdClusterHeartbeatManager

All Implemented Interfaces:

ClusterNodeHeartBeatDao, ClusterHeartbeatManager

public class CrowdClusterHeartbeatManager
extends Object
implements ClusterHeartbeatManager

Constructor Summary

Constructors

Constructor	Description
CrowdClusterHeartbeatManager(ClusterHeartbeatDAOHibernate dao, NodeDataProvider nodeDataProvider, com.atlassian.event.api.EventPublisher eventPublisher)

Method Summary

Modifier and Type	Method	Description
Collection<ClusterHeartbeatEntity>	findHeartbeatsAfter(long timestamp)
Collection<String>	findNodesWithHeartbeatsAfter(long timestamp)
Long	getLastHeartbeatTime(String nodeId)	Returns the last time a heartbeat was sent by the given node.
String	getNodeId()	Returns the globally unique Identifier for this cluster node.
int	removeHeartbeatsBefore(long timestamp)	Removes the heartbeats that heven't reported live before the given timestamp
void	writeHeartBeat(long time)	Writes a heartbeat for this node at the given time.

Methods inherited from class java.lang.Object

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

Constructor Details

CrowdClusterHeartbeatManager

public CrowdClusterHeartbeatManager(ClusterHeartbeatDAOHibernate dao,
 NodeDataProvider nodeDataProvider,
 com.atlassian.event.api.EventPublisher eventPublisher)

Method Details

getNodeId

@Nonnull
public String getNodeId()

Description copied from interface: ClusterNodeHeartBeatDao

Returns the globally unique Identifier for this cluster node.

Specified by:

getNodeId in interface ClusterNodeHeartBeatDao

Returns:

the globally unique Identifier for this cluster node.

writeHeartBeat

public void writeHeartBeat(long time)

Description copied from interface: ClusterNodeHeartBeatDao

Writes a heartbeat for this node at the given time. Caller will pass the time to stamp; in production this would normally be System.currentTimeMillis().

Specified by:

writeHeartBeat in interface ClusterNodeHeartBeatDao

Parameters:

time - the time in millis to write as the heartbeat.

getLastHeartbeatTime

@Nullable
public Long getLastHeartbeatTime(@Nonnull
 String nodeId)

Description copied from interface: ClusterNodeHeartBeatDao

Returns the last time a heartbeat was sent by the given node.

A null value indicates no heartbeats have been sent by this node.

Specified by:

getLastHeartbeatTime in interface ClusterNodeHeartBeatDao

Parameters:

nodeId - the node

Returns:

the last time a heartbeat was sent by the given node.

findNodesWithHeartbeatsAfter

@Nonnull
public Collection<String> findNodesWithHeartbeatsAfter(long timestamp)

Specified by:

findNodesWithHeartbeatsAfter in interface ClusterNodeHeartBeatDao

findHeartbeatsAfter

public Collection<ClusterHeartbeatEntity> findHeartbeatsAfter(long timestamp)

Specified by:

findHeartbeatsAfter in interface ClusterHeartbeatManager

Returns:

a list of hearbeats that reported live after the given timestamp

removeHeartbeatsBefore

public int removeHeartbeatsBefore(long timestamp)

Description copied from interface: ClusterHeartbeatManager

Removes the heartbeats that heven't reported live before the given timestamp

Specified by:

removeHeartbeatsBefore in interface ClusterHeartbeatManager

Returns:

the number of heartbeats removed