Package com.atlassian.confluence.security.denormalisedpermissions.impl.manage

Class DenormalisedLockService

java.lang.Object

com.atlassian.confluence.security.denormalisedpermissions.impl.manage.DenormalisedLockService

public class DenormalisedLockService
extends Object

Allows to acquire DB locks. Could be useful to prevent parallel execution.

Since:

7.11.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DenormalisedLockService.LockName

Constructor Summary

Constructors

Constructor	Description
DenormalisedLockService(org.hibernate.SessionFactory sessionFactory, org.springframework.transaction.PlatformTransactionManager transactionManager)

Method Summary

Modifier and Type	Method	Description
void	acquireLockForTransaction(DenormalisedLockService.LockName lockName)	Acquires the lock.
void	createAllLockRecordsIfTheyDoNotExist()	When the service is starting up for the first time, we need to create "state records".
DenormalisedLock	getRecord(DenormalisedLockService.LockName lockName)
void	onApplicationStarted(ApplicationStartedEvent applicationStartedEvent)

Methods inherited from class java.lang.Object

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

Constructor Details

DenormalisedLockService

public DenormalisedLockService(org.hibernate.SessionFactory sessionFactory,
 org.springframework.transaction.PlatformTransactionManager transactionManager)

Method Details

acquireLockForTransaction

public void acquireLockForTransaction(DenormalisedLockService.LockName lockName)

Acquires the lock. Must be called from an existing transaction. Released automatically when the transaction finishes

Parameters:

lockName - the name of the lock

getRecord

public DenormalisedLock getRecord(DenormalisedLockService.LockName lockName)

onApplicationStarted

@EventListener
public void onApplicationStarted(ApplicationStartedEvent applicationStartedEvent)

createAllLockRecordsIfTheyDoNotExist

public void createAllLockRecordsIfTheyDoNotExist()
                                          throws ExecutionException,
InterruptedException

When the service is starting up for the first time, we need to create "state records". It's important to do this in separate transaction because these records will be used for cluster-wide locking.

Throws:

ExecutionException

InterruptedException