com.atlassian.crowd.manager.cluster.heartbeat

Class CrowdClusterHeartbeatManager

java.lang.Object

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

All Implemented Interfaces:

com.atlassian.beehive.db.spi.ClusterNodeHeartBeatDao, ClusterHeartbeatManager

public class CrowdClusterHeartbeatManager
extends Object
implements ClusterHeartbeatManager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Collection<ClusterHeartbeatEntity>	findHeartbeatsAfter(long timestamp)
Collection<String>	findNodesWithHeartbeatsAfter(long timestamp)
Long	getLastHeartbeatTime(String nodeId)
String	getNodeId()
int	removeHeartbeatsBefore(long timestamp) Removes the heartbeats that heven't reported live before the given timestamp
void	writeHeartBeat(long time)

Methods inherited from class java.lang.Object

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

Constructor Detail

CrowdClusterHeartbeatManager

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

Method Detail

getNodeId

@Nonnull
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(@Nonnull
                                           String nodeId)

Specified by:

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

findNodesWithHeartbeatsAfter

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

Specified by:

findNodesWithHeartbeatsAfter in interface com.atlassian.beehive.db.spi.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