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

Class InVMNodeManager

java.lang.Object

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

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

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

All Implemented Interfaces:

ActiveMQComponent

public final class InVMNodeManager
extends FileBasedNodeManager

NodeManager used to run multiple servers in the same VM.

We use the InVMNodeManager instead of FileLockNodeManager when multiple servers are run inside the same VM and File Locks can not be shared in the same VM (it would cause a shared lock violation).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	InVMNodeManager.State

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

NodeManager.LockListener, NodeManager.NodeManagerException

Field Summary

Fields

Modifier and Type	Field	Description
long	failoverPause
InVMNodeManager.State	state

Fields inherited from class org.apache.activemq.artemis.core.server.impl.FileBasedNodeManager

activationSequenceChannel, channel, FIRST_TIME_START, SERVER_ACTIVATION_SEQUENCE_NAME, SERVER_LOCK_NAME, serverLockFile

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

nodeActivationSequence, nodeIDGuard, NULL_NODE_ACTIVATION_SEQUENCE, replicatedBackup

Constructor Summary

Constructors

Constructor	Description
InVMNodeManager(boolean replicatedBackup)
InVMNodeManager(boolean replicatedBackup, File directory)

Method Summary

Modifier and Type	Method	Description
void	awaitActiveStatus()
void	awaitPrimaryNode()
void	crashPrimaryServer()
void	interrupt()
boolean	isAwaitingFailback()
boolean	isBackupActive()
void	pausePrimaryServer()
SimpleString	readNodeId()
void	releaseBackup()
void	start()
void	startBackup()
ActivateCallback	startPrimaryNode()

Methods inherited from class org.apache.activemq.artemis.core.server.impl.FileBasedNodeManager

createNodeId, newFile, readNodeActivationSequence, setUpServerLockFile, stop, stopBackup, writeNodeActivationSequence

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

checkStarted, getNodeActivationSequence, getNodeId, getUUID, isStarted, notifyLostLock, registerLockListener, setNodeActivationSequence, setNodeID, setUUID, 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 Details

state

public volatile InVMNodeManager.State state

failoverPause

public long failoverPause

Constructor Details

InVMNodeManager

public InVMNodeManager(boolean replicatedBackup)

InVMNodeManager

public InVMNodeManager(boolean replicatedBackup,
 File directory)

Method Details

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Overrides:

start in class NodeManager

Throws:

Exception

awaitPrimaryNode

public void awaitPrimaryNode()
                      throws InterruptedException

Specified by:

awaitPrimaryNode in class NodeManager

Throws:

InterruptedException

awaitActiveStatus

public void awaitActiveStatus()
                       throws InterruptedException

Specified by:

awaitActiveStatus in class NodeManager

Throws:

InterruptedException

startBackup

public void startBackup()
                 throws InterruptedException

Specified by:

startBackup in class NodeManager

Throws:

InterruptedException

startPrimaryNode

public ActivateCallback startPrimaryNode()
                                  throws InterruptedException

Specified by:

startPrimaryNode in class NodeManager

Throws:

InterruptedException

pausePrimaryServer

public void pausePrimaryServer()

Specified by:

pausePrimaryServer in class NodeManager

crashPrimaryServer

public void crashPrimaryServer()

Specified by:

crashPrimaryServer in class NodeManager

isAwaitingFailback

public boolean isAwaitingFailback()

Specified by:

isAwaitingFailback in class NodeManager

isBackupActive

public boolean isBackupActive()

Specified by:

isBackupActive in class NodeManager

interrupt

public void interrupt()

Specified by:

interrupt in class NodeManager

releaseBackup

public void releaseBackup()

Specified by:

releaseBackup in class NodeManager

readNodeId

public SimpleString readNodeId()

Specified by:

readNodeId in class NodeManager