io.flamingock.store.mongodb.sync.internal

Class MongoDBSyncLockService

java.lang.Object

io.flamingock.store.mongodb.sync.internal.MongoDBSyncLockService

All Implemented Interfaces:

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

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	MongoDBSyncLockService(com.mongodb.client.MongoCollection<org.bson.Document> collection, com.mongodb.ReadConcern readConcern, com.mongodb.ReadPreference readPreference, com.mongodb.WriteConcern writeConcern, io.flamingock.internal.util.TimeService timeService)
	MongoDBSyncLockService(com.mongodb.client.MongoDatabase database, java.lang.String collectionName, com.mongodb.ReadConcern readConcern, com.mongodb.ReadPreference readPreference, com.mongodb.WriteConcern writeConcern, io.flamingock.internal.util.TimeService timeService)

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)
protected org.bson.conversions.Bson	getAcquireLockQuery(java.lang.String lockKey, java.lang.String owner, boolean onlyIfSameOwner)
io.flamingock.internal.core.external.store.lock.LockAcquisition	getLock(io.flamingock.internal.core.external.store.lock.LockKey lockKey)
void	initialize(boolean autoCreate)
protected void	insertUpdate(io.flamingock.internal.core.external.store.lock.community.CommunityLockEntry newLock, boolean onlyIfSameOwner)
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

MongoDBSyncLockService

public MongoDBSyncLockService(com.mongodb.client.MongoDatabase database,
                              java.lang.String collectionName,
                              com.mongodb.ReadConcern readConcern,
                              com.mongodb.ReadPreference readPreference,
                              com.mongodb.WriteConcern writeConcern,
                              io.flamingock.internal.util.TimeService timeService)

MongoDBSyncLockService

protected MongoDBSyncLockService(com.mongodb.client.MongoCollection<org.bson.Document> collection,
                                 com.mongodb.ReadConcern readConcern,
                                 com.mongodb.ReadPreference readPreference,
                                 com.mongodb.WriteConcern writeConcern,
                                 io.flamingock.internal.util.TimeService timeService)

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

insertUpdate

protected void insertUpdate(io.flamingock.internal.core.external.store.lock.community.CommunityLockEntry newLock,
                            boolean onlyIfSameOwner)

getAcquireLockQuery

protected org.bson.conversions.Bson getAcquireLockQuery(java.lang.String lockKey,
                                                        java.lang.String owner,
                                                        boolean onlyIfSameOwner)