com.atlassian.crowd.dao.cluster

Class ClusterHeartbeatDAOHibernate

java.lang.Object

com.atlassian.crowd.util.persistence.hibernate.StatelessDao

com.atlassian.crowd.util.persistence.hibernate.HibernateDao

com.atlassian.crowd.dao.cluster.ClusterHeartbeatDAOHibernate

public class ClusterHeartbeatDAOHibernate
extends HibernateDao

Hibernate DAO to store node heartbeats

Field Summary

Fields inherited from class com.atlassian.crowd.util.persistence.hibernate.HibernateDao

batchFinder, batchProcessor, logger, statelessSessionBatchProcessor, timeSource

Fields inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

sessionFactory

Constructor Summary

Constructors

Constructor and Description
ClusterHeartbeatDAOHibernate()

Method Summary

Modifier and Type	Method and Description
List<ClusterHeartbeatEntity>	findHeartbeatsAfter(long timestamp)
ClusterHeartbeatEntity	getHeartbeat(String nodeId)
Class<ClusterHeartbeatEntity>	getPersistentClass() All subclasses of HibernateDao must implement this method for HibernateDao.load(long) to work correctly.
int	removeHeartbeatsBefore(long timestamp)
void	writeHeartBeat(ClusterHeartbeatEntity heartbeatEntity) Inserts or updates the heartbeat entity
String	writeNewHeartbeat(Supplier<String> nodeIdSupplier, String nodeName, long timestamp) Tries to insert a new heartbeat based on the parameters.

Methods inherited from class com.atlassian.crowd.util.persistence.hibernate.HibernateDao

createHibernateQuery, load, load, loadReference, loadReference, remove, save, saveOrUpdate, session, setBatchFinder, setBatchProcessor, setClock, setStatelessSessionBatchProcessor, update

Methods inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

setSessionFactory, withStatelessSession

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterHeartbeatDAOHibernate

public ClusterHeartbeatDAOHibernate()

Method Detail

getPersistentClass

public Class<ClusterHeartbeatEntity> getPersistentClass()

Description copied from class: HibernateDao

All subclasses of HibernateDao must implement this method for HibernateDao.load(long) to work correctly.

Specified by:

getPersistentClass in class HibernateDao

Returns:

the entity class for this DAO

writeNewHeartbeat

public String writeNewHeartbeat(Supplier<String> nodeIdSupplier,
                                String nodeName,
                                long timestamp)
                         throws OperationFailedException

Tries to insert a new heartbeat based on the parameters. Should be used on node startup, to guarantee a unique nodeId. If the node id provided is already used, will call the supplier multiple times to obtain one that isn't.

Parameters:

nodeIdSupplier - a supplier of unique node ids

nodeName - the desired node names

timestamp - the desired timestamp of the heartbeat

Returns:

the node id for the successfully inserted heartbeat

Throws:

OperationFailedException - if insertion fails despite retries

writeHeartBeat

public void writeHeartBeat(ClusterHeartbeatEntity heartbeatEntity)
                    throws org.springframework.dao.DataAccessException

Inserts or updates the heartbeat entity

Throws:

org.springframework.dao.DataAccessException

getHeartbeat

@Nullable
public ClusterHeartbeatEntity getHeartbeat(String nodeId)

Parameters:

nodeId - the node id to find the heartbeat for

Returns:

the heartbeat entity, or null if not found

findHeartbeatsAfter

public List<ClusterHeartbeatEntity> findHeartbeatsAfter(long timestamp)

removeHeartbeatsBefore

public int removeHeartbeatsBefore(long timestamp)