public class FileLockNodeManager extends NodeManager
Modifier and Type | Field and Description |
---|---|
protected boolean |
interrupted |
channel, FIRST_TIME_START, replicatedBackup
Constructor and Description |
---|
FileLockNodeManager(String directory,
boolean replicatedBackup) |
Modifier and Type | Method and Description |
---|---|
void |
awaitLiveNode() |
void |
crashLiveServer() |
void |
interrupt() |
boolean |
isAwaitingFailback() |
boolean |
isBackupLive() |
boolean |
isLiveLocked() |
protected FileLock |
lock(int liveLockPos) |
void |
pauseLiveServer() |
SimpleString |
readNodeId() |
void |
releaseBackup() |
void |
start() |
void |
startBackup() |
void |
startLiveNode() |
protected FileLock |
tryLock(int lockPos) |
createNodeId, getNodeGroupName, getNodeId, getUUID, isStarted, newFile, setNodeGroupName, setNodeID, setUpServerLockFile, setUUID, stop, stopBackup
public FileLockNodeManager(String directory, boolean replicatedBackup)
public void start() throws Exception
start
in interface HornetQComponent
start
in class NodeManager
Exception
public boolean isAwaitingFailback() throws Exception
isAwaitingFailback
in class NodeManager
Exception
public boolean isBackupLive() throws Exception
isBackupLive
in class NodeManager
Exception
public boolean isLiveLocked()
public void interrupt()
interrupt
in class NodeManager
public final void releaseBackup() throws Exception
releaseBackup
in class NodeManager
Exception
public void awaitLiveNode() throws Exception
awaitLiveNode
in class NodeManager
Exception
public void startBackup() throws Exception
startBackup
in class NodeManager
Exception
public void startLiveNode() throws Exception
startLiveNode
in class NodeManager
Exception
public void pauseLiveServer() throws Exception
pauseLiveServer
in class NodeManager
Exception
public void crashLiveServer() throws Exception
crashLiveServer
in class NodeManager
Exception
public final SimpleString readNodeId() throws HornetQIllegalStateException, IOException
readNodeId
in class NodeManager
HornetQIllegalStateException
IOException
protected FileLock lock(int liveLockPos) throws IOException
IOException
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.