com.atlassian.crowd.cluster.message

Class SchemaAwareDatabaseClusterLockService

java.lang.Object

com.atlassian.beehive.db.DatabaseClusterLockService

com.atlassian.crowd.cluster.message.SchemaAwareDatabaseClusterLockService

All Implemented Interfaces:

com.atlassian.beehive.ClusterLockService, com.atlassian.beehive.core.ManagedClusterLockService

public class SchemaAwareDatabaseClusterLockService
extends com.atlassian.beehive.db.DatabaseClusterLockService

Constructor Summary

Constructors

Constructor and Description
SchemaAwareDatabaseClusterLockService(com.atlassian.beehive.db.spi.ClusterLockDao clusterLockDao, com.atlassian.beehive.db.ClusterNodeHeartbeatService clusterNodeHeartbeatService, SchemaUpToDateUtility schemaUpToDateUtility)

Method Summary

Modifier and Type	Method and Description
void	cleanUpOrphanLocks() This is necessary as this service will be instantiated before the upgrade phase, causing issues if the schema does not contain the heartbeat table (this will trigger getting the node id, which will be performed for the first time and will result in trying to write a heartbeat)

Methods inherited from class com.atlassian.beehive.db.DatabaseClusterLockService

getAllKnownClusterLocks, getLockForName

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaAwareDatabaseClusterLockService

public SchemaAwareDatabaseClusterLockService(com.atlassian.beehive.db.spi.ClusterLockDao clusterLockDao,
                                             com.atlassian.beehive.db.ClusterNodeHeartbeatService clusterNodeHeartbeatService,
                                             SchemaUpToDateUtility schemaUpToDateUtility)

Method Detail

cleanUpOrphanLocks

@PostConstruct
public void cleanUpOrphanLocks()

This is necessary as this service will be instantiated before the upgrade phase, causing issues if the schema does not contain the heartbeat table (this will trigger getting the node id, which will be performed for the first time and will result in trying to write a heartbeat)

Overrides:

cleanUpOrphanLocks in class com.atlassian.beehive.db.DatabaseClusterLockService