Package 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	Description
void	addLock(String action, String lockType)
void	aquireInfiniteLock(String action)
void	clearAllLocks()
void	clearInfiniteLock(String action)
Map<String,Lock>	findLocks()
String	getInstanceId()
String	getServerId()
void	init()
boolean	isClusteringEnabled()
boolean	isInfiniteLocked(String action)
boolean	isLocked(String action)
boolean	lock(String action)
boolean	lock(String action, String lockType)
boolean	lock(String action, String lockType, long waitMillis)
void	persistToTableForSnapshot()
boolean	refreshLock(String action)
void	refreshLockEntries()
void	removeLock(String action)
void	unlock(String action)
void	unlock(String action, String lockType)

Method Details

init

void init()

refreshLockEntries

void refreshLockEntries()

lock

boolean lock(String action)

refreshLock

boolean refreshLock(String action)

lock

boolean lock(String action,
 String lockType)

lock

boolean lock(String action,
 String lockType,
 long waitMillis)

unlock

void unlock(String action)

unlock

void unlock(String action,
 String lockType)

clearAllLocks

void clearAllLocks()

addLock

void addLock(String action,
 String lockType)

removeLock

void removeLock(String action)

getServerId

String getServerId()

isClusteringEnabled

boolean isClusteringEnabled()

findLocks

Map<String,Lock> findLocks()

aquireInfiniteLock

void aquireInfiniteLock(String action)

clearInfiniteLock

void clearInfiniteLock(String action)

isInfiniteLocked

boolean isInfiniteLocked(String action)

isLocked

boolean isLocked(String action)

persistToTableForSnapshot

void persistToTableForSnapshot()

getInstanceId

String getInstanceId()