com.atlassian.beehive.db.spi

Class UnreliableMockClusterLockDao

java.lang.Object

com.atlassian.beehive.db.spi.UnreliableMockClusterLockDao

All Implemented Interfaces:

ClusterLockDao

public class UnreliableMockClusterLockDao
extends Object
implements ClusterLockDao

A ClusterLockDao that can be configured to simulate network/db failures.

Since:

v2.0.1

Constructor Summary

Constructors

Constructor and Description
UnreliableMockClusterLockDao(ClusterLockDao delegate, FailureStrategy failureStrategy)

Method Summary

Modifier and Type	Method and Description
List<ClusterLockStatus>	getAllHeldClusterLocks()
ClusterLockStatus	getClusterLockStatusByName(String lockName)
FailureStrategy	getFailureStrategy()
void	insertEmptyClusterLock(String lockName)
void	releaseLocksHeldByNode()
void	renewLease(String lockName)
void	setFailureStrategy(FailureStrategy failureStrategy)
boolean	tryAcquireLock(String lockName)
void	unlock(String lockName)

Methods inherited from class java.lang.Object

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

Constructor Detail

UnreliableMockClusterLockDao

public UnreliableMockClusterLockDao(ClusterLockDao delegate,
                                    FailureStrategy failureStrategy)

Method Detail

getFailureStrategy

public FailureStrategy getFailureStrategy()

setFailureStrategy

public void setFailureStrategy(FailureStrategy failureStrategy)

getAllHeldClusterLocks

@Nonnull
public List<ClusterLockStatus> getAllHeldClusterLocks()

Specified by:

getAllHeldClusterLocks in interface ClusterLockDao

getClusterLockStatusByName

@Nullable
public ClusterLockStatus getClusterLockStatusByName(@Nonnull
                                                              String lockName)

Specified by:

getClusterLockStatusByName in interface ClusterLockDao

tryAcquireLock

public boolean tryAcquireLock(@Nonnull
                              String lockName)

Specified by:

tryAcquireLock in interface ClusterLockDao

insertEmptyClusterLock

public void insertEmptyClusterLock(@Nonnull
                                   String lockName)

Specified by:

insertEmptyClusterLock in interface ClusterLockDao

unlock

public void unlock(@Nonnull
                   String lockName)

Specified by:

unlock in interface ClusterLockDao

releaseLocksHeldByNode

public void releaseLocksHeldByNode()

Specified by:

releaseLocksHeldByNode in interface ClusterLockDao

renewLease

public void renewLease(@Nonnull
                       String lockName)

Specified by:

renewLease in interface ClusterLockDao