com.github.cloudyrock.mongock.driver.core.driver

Class ConnectionDriverBase<CHANGE_ENTRY extends ChangeEntry>

java.lang.Object

com.github.cloudyrock.mongock.driver.core.driver.ConnectionDriverBase<CHANGE_ENTRY>

All Implemented Interfaces:

Validable, ConnectionDriver<CHANGE_ENTRY>

@NotThreadSafe
public abstract class ConnectionDriverBase<CHANGE_ENTRY extends ChangeEntry>
extends Object
implements ConnectionDriver<CHANGE_ENTRY>

Constructor Summary

Constructors

Constructor and Description
ConnectionDriverBase()
ConnectionDriverBase(long lockAcquiredForMinutes, long maxWaitingForLockMinutes, int maxTries)

Method Summary

Modifier and Type	Method and Description
LockManager	getAndAcquireLockManager()
String	getChangeLogRepositoryName()
long	getLockAcquiredForMinutes()
LockManager	getLockManager()
protected abstract LockRepository	getLockRepository()
String	getLockRepositoryName()
int	getMaxTries()
long	getMaxWaitingForLockMinutes()
void	initialize()
boolean	isIndexCreation()
boolean	isInitialized()
void	runValidation()
void	setChangeLogRepositoryName(String changeLogRepositoryName)
void	setIndexCreation(boolean indexCreation)
void	setLockAcquiredForMinutes(long lockAcquiredForMinutes)
void	setLockRepositoryName(String lockRepositoryName)
void	setMaxTries(int maxTries)
void	setMaxWaitingForLockMinutes(long maxWaitingForLockMinutes)
protected abstract void	specificInitialization()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.github.cloudyrock.mongock.driver.api.driver.ConnectionDriver

getChangeEntryService, getDependencies, getForbiddenParameters, getLegacyMigrationChangeLogClass

Constructor Detail

ConnectionDriverBase

public ConnectionDriverBase()

ConnectionDriverBase

public ConnectionDriverBase(long lockAcquiredForMinutes,
                            long maxWaitingForLockMinutes,
                            int maxTries)

Method Detail

initialize

public final void initialize()

Specified by:

initialize in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getLockManager

public LockManager getLockManager()

Specified by:

getLockManager in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getAndAcquireLockManager

public LockManager getAndAcquireLockManager()

Specified by:

getAndAcquireLockManager in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getLockAcquiredForMinutes

public long getLockAcquiredForMinutes()

Specified by:

getLockAcquiredForMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getMaxWaitingForLockMinutes

public long getMaxWaitingForLockMinutes()

Specified by:

getMaxWaitingForLockMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getMaxTries

public int getMaxTries()

Specified by:

getMaxTries in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getChangeLogRepositoryName

public String getChangeLogRepositoryName()

Specified by:

getChangeLogRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getLockRepositoryName

public String getLockRepositoryName()

Specified by:

getLockRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

isIndexCreation

public boolean isIndexCreation()

Specified by:

isIndexCreation in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

setLockAcquiredForMinutes

public void setLockAcquiredForMinutes(long lockAcquiredForMinutes)

Specified by:

setLockAcquiredForMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

setMaxWaitingForLockMinutes

public void setMaxWaitingForLockMinutes(long maxWaitingForLockMinutes)

Specified by:

setMaxWaitingForLockMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

setMaxTries

public void setMaxTries(int maxTries)

Specified by:

setMaxTries in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

setChangeLogRepositoryName

public void setChangeLogRepositoryName(String changeLogRepositoryName)

Specified by:

setChangeLogRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

setLockRepositoryName

public void setLockRepositoryName(String lockRepositoryName)

Specified by:

setLockRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

setIndexCreation

public void setIndexCreation(boolean indexCreation)

Specified by:

setIndexCreation in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>

getLockRepository

protected abstract LockRepository getLockRepository()

specificInitialization

protected abstract void specificInitialization()

runValidation

public void runValidation()
                   throws MongockException

Specified by:

runValidation in interface Validable

Throws:

MongockException