com.atlassian.beehive
Class DatabaseClusterLockService

java.lang.Object
  com.atlassian.beehive.DatabaseClusterLockService

All Implemented Interfaces:

ClusterLockService

public class DatabaseClusterLockService
extends Object
implements ClusterLockService

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.

Applications whose dependency injection container does not support the JSR-250 PostConstruct annotation will need to explicitly invoke the cleanUpOrphanLocks() method upon startup or the first lock attempt.

See Also:

SimpleClusterLockService

Constructor Summary

DatabaseClusterLockService(ClusterLockDao clusterLockDao, ClusterNodeHeartbeatService clusterNodeHeartbeatService)

Method Summary

void	cleanUpOrphanLocks()
ClusterLock	getLockForName(String lockName) Returns the cluster-wide lock for the given name.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseClusterLockService

public DatabaseClusterLockService(ClusterLockDao clusterLockDao,
                                  ClusterNodeHeartbeatService clusterNodeHeartbeatService)

Method Detail

cleanUpOrphanLocks

@PostConstruct
public void cleanUpOrphanLocks()

getLockForName

public ClusterLock getLockForName(@Nonnull
                                  String lockName)

Description copied from interface: ClusterLockService

Returns the cluster-wide lock for the given name.

Specified by:

getLockForName in interface ClusterLockService

Parameters:

lockName - the globally unique lock identifier

Returns:

the cluster-wide lock for the given name.