org.jumpmind.symmetric.service

Interface IClusterService

All Known Implementing Classes:

ClusterService

public interface IClusterService

Service API that is responsible for acquiring distributed locks for clustered SymmetricDS nodes.

Method Summary

Modifier and Type	Method and Description
void	aquireInfiniteLock(java.lang.String action)
void	clearAllLocks()
void	clearInfiniteLock(java.lang.String action)
java.util.Map<java.lang.String,Lock>	findLocks()
java.lang.String	getInstanceId()
java.lang.String	getServerId()
void	init()
boolean	isClusteringEnabled()
boolean	isInfiniteLocked(java.lang.String action)
boolean	lock(java.lang.String action)
boolean	lock(java.lang.String action, java.lang.String lockType)
boolean	lock(java.lang.String action, java.lang.String lockType, long waitMillis)
void	persistToTableForSnapshot()
boolean	refreshLock(java.lang.String action)
void	refreshLockEntries()
void	unlock(java.lang.String action)
void	unlock(java.lang.String action, java.lang.String lockType)

Method Detail

init

void init()

refreshLockEntries

void refreshLockEntries()

lock

boolean lock(java.lang.String action)

refreshLock

boolean refreshLock(java.lang.String action)

lock

boolean lock(java.lang.String action,
             java.lang.String lockType)

lock

boolean lock(java.lang.String action,
             java.lang.String lockType,
             long waitMillis)

unlock

void unlock(java.lang.String action)

unlock

void unlock(java.lang.String action,
            java.lang.String lockType)

clearAllLocks

void clearAllLocks()

getServerId

java.lang.String getServerId()

isClusteringEnabled

boolean isClusteringEnabled()

findLocks

java.util.Map<java.lang.String,Lock> findLocks()

aquireInfiniteLock

void aquireInfiniteLock(java.lang.String action)

clearInfiniteLock

void clearInfiniteLock(java.lang.String action)

isInfiniteLocked

boolean isInfiniteLocked(java.lang.String action)

persistToTableForSnapshot

void persistToTableForSnapshot()

getInstanceId

java.lang.String getInstanceId()