Package org.apache.ignite.internal.cdc

Class CdcFileLockHolder

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.FileLockHolder

org.apache.ignite.internal.cdc.CdcFileLockHolder

All Implemented Interfaces:

AutoCloseable

public class CdcFileLockHolder
extends FileLockHolder

Lock file holder for Change Data Capture application.

See Also:

CdcMain, CdcConsumerState

Constructor Summary

Constructors

Constructor	Description
CdcFileLockHolder(String rootDir, String consumerId, IgniteLogger log)

Method Summary

Modifier and Type	Method	Description
String	lockInfo()	This info will appear in error message of concurrent processes that will try to lock on the same file.
protected String	warningMessage(String lockInfo)

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.FileLockHolder

close, isLocked, lockPath, release, tryLock

Methods inherited from class java.lang.Object

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

Constructor Detail

CdcFileLockHolder

public CdcFileLockHolder(String rootDir,
                         String consumerId,
                         IgniteLogger log)

Parameters:

rootDir - Root directory for lock file.

log - Log.

Method Detail

lockInfo

public String lockInfo()

This info will appear in error message of concurrent processes that will try to lock on the same file.

Specified by:

lockInfo in class FileLockHolder

Returns:

Lock info to store in the file.

warningMessage

protected String warningMessage(String lockInfo)

Specified by:

warningMessage in class FileLockHolder

Parameters:

lockInfo - Existing lock info.

Returns:

Warning message.