Package com.broadleafcommerce.search.index.ignite

Class IgniteLockService

java.lang.Object

com.broadleafcommerce.search.index.ignite.IgniteLockService

All Implemented Interfaces:

com.broadleafcommerce.search.index.core.Distributable, com.broadleafcommerce.search.index.core.LockService, org.springframework.beans.factory.DisposableBean

public class IgniteLockService
extends Object
implements com.broadleafcommerce.search.index.core.LockService, org.springframework.beans.factory.DisposableBean

Default implementation of a LockService that provides a distributed Lock mechanism based on functionality provided by Apache Ignite.

Author:

Kelly Tisdell (ktisdell)

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEFAULT_REINDEX_LOCK_CACHE_NAME

Constructor Summary

Constructors

Constructor	Description
IgniteLockService(org.apache.ignite.Ignite ignite, org.apache.ignite.configuration.CacheConfiguration<String,Object> cacheConfig)

Method Summary

Modifier and Type	Method	Description
void	destroy()
protected org.apache.ignite.IgniteCache<String,Object>	getCache()
boolean	isDistributed()
boolean	isLocked(String lockName)
String	lock(String lockName)
void	unlock(String lockName, String lockKey)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_REINDEX_LOCK_CACHE_NAME

public static final String DEFAULT_REINDEX_LOCK_CACHE_NAME

See Also:

Constant Field Values

Constructor Detail

IgniteLockService

public IgniteLockService(org.apache.ignite.Ignite ignite,
                         org.apache.ignite.configuration.CacheConfiguration<String,Object> cacheConfig)

Method Detail

isDistributed

public final boolean isDistributed()

Specified by:

isDistributed in interface com.broadleafcommerce.search.index.core.Distributable

isLocked

public boolean isLocked(@NonNull
                        String lockName)

Specified by:

isLocked in interface com.broadleafcommerce.search.index.core.LockService

lock

public String lock(@NonNull
                   String lockName)
            throws com.broadleafcommerce.search.index.core.LockException

Specified by:

lock in interface com.broadleafcommerce.search.index.core.LockService

Throws:

com.broadleafcommerce.search.index.core.LockException

unlock

public void unlock(@NonNull
                   String lockName,
                   @NonNull
                   String lockKey)
            throws com.broadleafcommerce.search.index.core.LockException

Specified by:

unlock in interface com.broadleafcommerce.search.index.core.LockService

Throws:

com.broadleafcommerce.search.index.core.LockException

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

getCache

protected final org.apache.ignite.IgniteCache<String,Object> getCache()