org.apache.activemq.artemis.core.server.impl

Class FileLockNodeManager

java.lang.Object

org.apache.activemq.artemis.core.server.NodeManager

org.apache.activemq.artemis.core.server.impl.FileLockNodeManager

All Implemented Interfaces:

ActiveMQComponent

public class FileLockNodeManager
extends NodeManager

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	interrupted
protected long	lockAcquisitionTimeout

Fields inherited from class org.apache.activemq.artemis.core.server.NodeManager

channel, FIRST_TIME_START, replicatedBackup

Constructor Summary

Constructors

Constructor and Description
FileLockNodeManager(File directory, boolean replicatedBackup)
FileLockNodeManager(File directory, boolean replicatedBackup, long lockAcquisitionTimeout)

Method Summary

Modifier and Type	Method and Description
void	awaitLiveNode()
void	awaitLiveStatus()
void	crashLiveServer()
void	interrupt()
boolean	isAwaitingFailback()
boolean	isBackupLive()
boolean	isLiveLocked()
protected FileLock	lock(long lockPosition)
void	pauseLiveServer()
SimpleString	readNodeId()
void	releaseBackup()
void	start()
void	startBackup()
ActivateCallback	startLiveNode()
protected FileLock	tryLock(long lockPos)

Methods inherited from class org.apache.activemq.artemis.core.server.NodeManager

createNodeId, getNodeId, getUUID, isStarted, newFile, setNodeID, setUpServerLockFile, setUUID, stop, stopBackup

Methods inherited from class java.lang.Object

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

Field Detail

lockAcquisitionTimeout

protected long lockAcquisitionTimeout

interrupted

protected boolean interrupted

Constructor Detail

FileLockNodeManager

public FileLockNodeManager(File directory,
                           boolean replicatedBackup)

FileLockNodeManager

public FileLockNodeManager(File directory,
                           boolean replicatedBackup,
                           long lockAcquisitionTimeout)

Method Detail

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Overrides:

start in class NodeManager

Throws:

Exception

isAwaitingFailback

public boolean isAwaitingFailback()
                           throws Exception

Specified by:

isAwaitingFailback in class NodeManager

Throws:

Exception

isBackupLive

public boolean isBackupLive()
                     throws Exception

Specified by:

isBackupLive in class NodeManager

Throws:

Exception

isLiveLocked

public boolean isLiveLocked()

interrupt

public void interrupt()

Specified by:

interrupt in class NodeManager

releaseBackup

public final void releaseBackup()
                         throws Exception

Specified by:

releaseBackup in class NodeManager

Throws:

Exception

awaitLiveNode

public void awaitLiveNode()
                   throws Exception

Specified by:

awaitLiveNode in class NodeManager

Throws:

Exception

startBackup

public void startBackup()
                 throws Exception

Specified by:

startBackup in class NodeManager

Throws:

Exception

startLiveNode

public ActivateCallback startLiveNode()
                               throws Exception

Specified by:

startLiveNode in class NodeManager

Throws:

Exception

pauseLiveServer

public void pauseLiveServer()
                     throws Exception

Specified by:

pauseLiveServer in class NodeManager

Throws:

Exception

crashLiveServer

public void crashLiveServer()
                     throws Exception

Specified by:

crashLiveServer in class NodeManager

Throws:

Exception

awaitLiveStatus

public void awaitLiveStatus()
                     throws Exception

Specified by:

awaitLiveStatus in class NodeManager

Throws:

Exception

readNodeId

public final SimpleString readNodeId()
                              throws ActiveMQIllegalStateException,
                                     IOException

Specified by:

readNodeId in class NodeManager

Throws:

ActiveMQIllegalStateException

IOException

tryLock

protected FileLock tryLock(long lockPos)
                    throws IOException

Throws:

IOException

lock

protected FileLock lock(long lockPosition)
                 throws Exception

Throws:

Exception