de.hybris.platform.core.system.impl

Class DefaultInitLockDao

java.lang.Object

de.hybris.platform.core.system.impl.DefaultInitLockDao

All Implemented Interfaces:

InitializationLockDao, Serializable

public class DefaultInitLockDao
extends Object
implements InitializationLockDao

Implementation of the InitializationLockDao.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultInitLockDao()
DefaultInitLockDao(QueryProvider queryProvider)

Method Summary

Modifier and Type	Method and Description
void	createTable() Optionally creates table.
protected HybrisDataSource	getInitializedMasterDataSource() Method reinitializes a instance property to most accurate, so as a result we would have always an open HybrisDataSource if possible.
long	getUniqueInstanceIdentifier() Identifier specific for running platform.
boolean	insertRow() Optionally inserts lock row.
boolean	lockRow(Tenant forTenant, String processName) Locks row using cluster node ID from given tenant.
InitializationLockInfo	readLockInfo() Reads current locking information.
boolean	releaseRow(Tenant forTenant) Releases existing lock.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultInitLockDao

public DefaultInitLockDao()

DefaultInitLockDao

public DefaultInitLockDao(QueryProvider queryProvider)

Method Detail

getInitializedMasterDataSource

protected HybrisDataSource getInitializedMasterDataSource()

Method reinitializes a instance property to most accurate, so as a result we would have always an open HybrisDataSource if possible.

readLockInfo

public InitializationLockInfo readLockInfo()

Description copied from interface: InitializationLockDao

Reads current locking information.

Specified by:

readLockInfo in interface InitializationLockDao

Returns:

null if no lock row or table exists, the info object otherwise

lockRow

public boolean lockRow(Tenant forTenant,
                       String processName)

Description copied from interface: InitializationLockDao

Locks row using cluster node ID from given tenant. Requires lock not being taken before (no matter by which cluster node!).

Specified by:

lockRow in interface InitializationLockDao

releaseRow

public boolean releaseRow(Tenant forTenant)

Description copied from interface: InitializationLockDao

Releases existing lock. Tenant must have cluster node ID that matches the one inside the lock!

Specified by:

releaseRow in interface InitializationLockDao

insertRow

public boolean insertRow()

Description copied from interface: InitializationLockDao

Optionally inserts lock row.

Specified by:

insertRow in interface InitializationLockDao

Returns:

true if row could be inserted or row already exists, false on other errors (e.g. table not existing)

createTable

public void createTable()

Description copied from interface: InitializationLockDao

Optionally creates table. If table already exists it does nothing.

Specified by:

createTable in interface InitializationLockDao

getUniqueInstanceIdentifier

public long getUniqueInstanceIdentifier()

Description copied from interface: InitializationLockDao

Identifier specific for running platform. Every platform startup standalone or other should have own unique identifier.

Specified by:

getUniqueInstanceIdentifier in interface InitializationLockDao