@NotThreadSafe public abstract class ConnectionDriverBase<CHANGE_ENTRY extends ChangeEntry> extends Object implements ConnectionDriver<CHANGE_ENTRY>
| Constructor and Description |
|---|
ConnectionDriverBase() |
ConnectionDriverBase(long lockAcquiredForMinutes,
long maxWaitingForLockMinutes,
int maxTries) |
| 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() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetChangeEntryService, getDependencies, getForbiddenParameters, getLegacyMigrationChangeLogClasspublic ConnectionDriverBase()
public ConnectionDriverBase(long lockAcquiredForMinutes,
long maxWaitingForLockMinutes,
int maxTries)
public final void initialize()
initialize in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public LockManager getLockManager()
getLockManager in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public LockManager getAndAcquireLockManager()
getAndAcquireLockManager in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public boolean isInitialized()
isInitialized in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public long getLockAcquiredForMinutes()
getLockAcquiredForMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public long getMaxWaitingForLockMinutes()
getMaxWaitingForLockMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public int getMaxTries()
getMaxTries in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public String getChangeLogRepositoryName()
getChangeLogRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public String getLockRepositoryName()
getLockRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public boolean isIndexCreation()
isIndexCreation in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public void setLockAcquiredForMinutes(long lockAcquiredForMinutes)
setLockAcquiredForMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public void setMaxWaitingForLockMinutes(long maxWaitingForLockMinutes)
setMaxWaitingForLockMinutes in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public void setMaxTries(int maxTries)
setMaxTries in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public void setChangeLogRepositoryName(String changeLogRepositoryName)
setChangeLogRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public void setLockRepositoryName(String lockRepositoryName)
setLockRepositoryName in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>public void setIndexCreation(boolean indexCreation)
setIndexCreation in interface ConnectionDriver<CHANGE_ENTRY extends ChangeEntry>protected abstract LockRepository getLockRepository()
protected abstract void specificInitialization()
public void runValidation()
throws MongockException
runValidation in interface ValidableMongockExceptionCopyright © 2021. All rights reserved.