io.flamingock.store.sql.internal

Class SqlLockService

java.lang.Object

io.flamingock.store.sql.internal.SqlLockService

All Implemented Interfaces:

io.flamingock.internal.core.external.store.lock.community.CommunityLockService, io.flamingock.internal.core.external.store.lock.LockService

public class SqlLockService
extends java.lang.Object
implements io.flamingock.internal.core.external.store.lock.community.CommunityLockService

Constructor Summary

Constructors

Constructor and Description
SqlLockService(javax.sql.DataSource dataSource, java.lang.String lockRepositoryName)

Method Summary

Modifier and Type	Method and Description
io.flamingock.internal.core.external.store.lock.LockAcquisition	extendLock(io.flamingock.internal.core.external.store.lock.LockKey key, io.flamingock.internal.util.id.RunnerId owner, long leaseMillis)
io.flamingock.internal.core.external.store.lock.LockAcquisition	getLock(io.flamingock.internal.core.external.store.lock.LockKey lockKey)
void	initialize(boolean autoCreate)
void	releaseLock(io.flamingock.internal.core.external.store.lock.LockKey lockKey, io.flamingock.internal.util.id.RunnerId owner)
io.flamingock.internal.core.external.store.lock.LockAcquisition	upsert(io.flamingock.internal.core.external.store.lock.LockKey key, io.flamingock.internal.util.id.RunnerId owner, long leaseMillis)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlLockService

public SqlLockService(javax.sql.DataSource dataSource,
                      java.lang.String lockRepositoryName)

Method Detail

initialize

public void initialize(boolean autoCreate)

upsert

public io.flamingock.internal.core.external.store.lock.LockAcquisition upsert(io.flamingock.internal.core.external.store.lock.LockKey key,
                                                                              io.flamingock.internal.util.id.RunnerId owner,
                                                                              long leaseMillis)

Specified by:

upsert in interface io.flamingock.internal.core.external.store.lock.community.CommunityLockService

extendLock

public io.flamingock.internal.core.external.store.lock.LockAcquisition extendLock(io.flamingock.internal.core.external.store.lock.LockKey key,
                                                                                  io.flamingock.internal.util.id.RunnerId owner,
                                                                                  long leaseMillis)
                                                                           throws io.flamingock.internal.core.external.store.lock.LockServiceException

Specified by:

extendLock in interface io.flamingock.internal.core.external.store.lock.LockService

Throws:

io.flamingock.internal.core.external.store.lock.LockServiceException

getLock

public io.flamingock.internal.core.external.store.lock.LockAcquisition getLock(io.flamingock.internal.core.external.store.lock.LockKey lockKey)

Specified by:

getLock in interface io.flamingock.internal.core.external.store.lock.LockService

releaseLock

public void releaseLock(io.flamingock.internal.core.external.store.lock.LockKey lockKey,
                        io.flamingock.internal.util.id.RunnerId owner)

Specified by:

releaseLock in interface io.flamingock.internal.core.external.store.lock.LockService