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

Class FileBasedNodeManager

java.lang.Object

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

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

All Implemented Interfaces:

ActiveMQComponent

Direct Known Subclasses:

FileLockNodeManager, InVMNodeManager

public abstract class FileBasedNodeManager
extends NodeManager

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.activemq.artemis.core.server.NodeManager

NodeManager.LockListener, NodeManager.NodeManagerException

Field Summary

Fields

Modifier and Type	Field and Description
protected FileChannel	channel
protected static byte	FIRST_TIME_START
static String	SERVER_LOCK_NAME

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

nodeIDGuard, replicatedBackup

Constructor Summary

Constructors

Constructor and Description
FileBasedNodeManager(boolean replicatedBackup, File directory)

Method Summary

Modifier and Type	Method and Description
protected void	createNodeId()
protected File	newFile(String fileName)
protected void	setUpServerLockFile() Ensures existence of persistent information about the server's nodeID.
void	stop()
void	stopBackup()

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

awaitLiveNode, awaitLiveStatus, checkStarted, crashLiveServer, getNodeId, getUUID, interrupt, isAwaitingFailback, isBackupLive, isStarted, notifyLostLock, pauseLiveServer, readNodeId, registerLockListener, releaseBackup, setNodeID, setUUID, start, startBackup, startLiveNode, unregisterLockListener

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Field Detail

FIRST_TIME_START

protected static final byte FIRST_TIME_START

See Also:

Constant Field Values

SERVER_LOCK_NAME

public static final String SERVER_LOCK_NAME

See Also:

Constant Field Values

channel

protected FileChannel channel

Constructor Detail

FileBasedNodeManager

public FileBasedNodeManager(boolean replicatedBackup,
                            File directory)

Method Detail

setUpServerLockFile

protected void setUpServerLockFile()
                            throws IOException

Ensures existence of persistent information about the server's nodeID.

Roughly the different use cases are:

1. old live server restarts: a server.lock file already exists and contains a nodeID.
2. new live server starting for the first time: no file exists, and we just *create* a new UUID to use as nodeID
3. replicated backup received its nodeID from its live: no file exists, we need to persist the *current* nodeID

Throws:

IOException

newFile

protected final File newFile(String fileName)

Returns:

createNodeId

protected final void createNodeId()
                           throws IOException

Throws:

IOException

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Overrides:

stop in class NodeManager

Throws:

Exception

stopBackup

public void stopBackup()
                throws NodeManager.NodeManagerException

Overrides:

stopBackup in class NodeManager

Throws:

NodeManager.NodeManagerException