Package org.keycloak.connections.jpa.updater.liquibase.lock

Class CustomLockService

java.lang.Object

liquibase.lockservice.StandardLockService

org.keycloak.connections.jpa.updater.liquibase.lock.CustomLockService

All Implemented Interfaces:

liquibase.lockservice.LockService, liquibase.servicelocator.PrioritizedService

public class CustomLockService
extends liquibase.lockservice.StandardLockService

Liquibase lock service, which has some bugfixes and assumes timeouts to be configured in milliseconds

Author:

Marek Posolda

Field Summary

Fields inherited from class liquibase.lockservice.StandardLockService

changeLogLockPollRate, changeLogLockRecheckTime, coreBundle, database, hasChangeLogLock, hasDatabaseChangeLogLockTable, isDatabaseChangeLogLockTableInitialized, quotingStrategy, random

Fields inherited from interface liquibase.servicelocator.PrioritizedService

COMPARATOR, PRIORITY_DATABASE, PRIORITY_DEFAULT

Constructor Summary

Constructors

Constructor	Description
CustomLockService()

Method Summary

Modifier and Type	Method	Description
boolean	acquireLock()
protected boolean	hasDatabaseChangeLogLockTable()
void	init()
void	releaseLock()
void	waitForLock()
void	waitForLock(DBLockProvider.Namespace lock)

Methods inherited from class liquibase.lockservice.StandardLockService

destroy, forceReleaseLock, getChangeLogLockRecheckTime, getChangeLogLockWaitTime, getPriority, hasChangeLogLock, hasDatabaseChangeLogLockTable, isDatabaseChangeLogLockTableInitialized, isDatabaseChangeLogLockTableInitialized, listLocks, reset, setChangeLogLockRecheckTime, setChangeLogLockWaitTime, setDatabase, supports

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomLockService

public CustomLockService()

Method Detail

hasDatabaseChangeLogLockTable

protected boolean hasDatabaseChangeLogLockTable()
                                         throws liquibase.exception.DatabaseException

Overrides:

hasDatabaseChangeLogLockTable in class liquibase.lockservice.StandardLockService

Throws:

liquibase.exception.DatabaseException

init

public void init()
          throws liquibase.exception.DatabaseException

Specified by:

init in interface liquibase.lockservice.LockService

Overrides:

init in class liquibase.lockservice.StandardLockService

Throws:

liquibase.exception.DatabaseException

waitForLock

public void waitForLock()

Specified by:

waitForLock in interface liquibase.lockservice.LockService

Overrides:

waitForLock in class liquibase.lockservice.StandardLockService

waitForLock

public void waitForLock(DBLockProvider.Namespace lock)

acquireLock

public boolean acquireLock()

Specified by:

acquireLock in interface liquibase.lockservice.LockService

Overrides:

acquireLock in class liquibase.lockservice.StandardLockService

releaseLock

public void releaseLock()

Specified by:

releaseLock in interface liquibase.lockservice.LockService

Overrides:

releaseLock in class liquibase.lockservice.StandardLockService