Package com.atlassian.beehive.db

Class DatabaseClusterLockService

java.lang.Object

com.atlassian.beehive.db.DatabaseClusterLockService

All Implemented Interfaces:

ClusterLockService, ManagedClusterLockService

public class DatabaseClusterLockService
extends Object
implements ManagedClusterLockService

This is the database backed implementation of ClusterLockService that can be used by clustered applications.

This implementation relies on the host application providing SPI implementations for Data Access objects.

Warning: Any alterations of tables used by DAO SPI implementations, if performed at runtime, need to be followed by calling resetDatabaseState(). Failing to do so immediately after the changes, may result in unexpected locks behavior. Furthermore, the existing unreleased locks, that were held since before the db alteration, no logner guarantee clusterwide exclusiveness until they are successfully reacquired.

Constructor Summary

Constructors

Constructor	Description
DatabaseClusterLockService(ClusterLockDao clusterLockDao)

Method Summary

Modifier and Type	Method	Description
Collection<com.atlassian.beehive.db.DatabaseClusterLock>	getAllKnownClusterLocks()
ClusterLock	getLockForName(String lockName)
Collection<ClusterLockStatus>	getStatusesOfAllHeldClusterLocks()
void	resetDatabaseState()	Reset internal state of the locks to adjust to external changes in tables used by DAO at runtime.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

DatabaseClusterLockService

public DatabaseClusterLockService(ClusterLockDao clusterLockDao)

Method Details

getAllKnownClusterLocks

public Collection<com.atlassian.beehive.db.DatabaseClusterLock> getAllKnownClusterLocks()

Specified by:

getAllKnownClusterLocks in interface ManagedClusterLockService

getStatusesOfAllHeldClusterLocks

@Nonnull
public Collection<ClusterLockStatus> getStatusesOfAllHeldClusterLocks()

Specified by:

getStatusesOfAllHeldClusterLocks in interface ManagedClusterLockService

getLockForName

public ClusterLock getLockForName(@Nonnull
 String lockName)

Specified by:

getLockForName in interface ClusterLockService

shutdown

@PreDestroy
public void shutdown()

resetDatabaseState

public void resetDatabaseState()

Reset internal state of the locks to adjust to external changes in tables used by DAO at runtime.