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.InVMNodeManager

All Implemented Interfaces:

ActiveMQComponent

public final class InVMNodeManager
extends NodeManager

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 and Description
static class	InVMNodeManager.State

Field Summary

Fields

Modifier and Type	Field and Description
long	failoverPause
InVMNodeManager.State	state

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

channel, FIRST_TIME_START, replicatedBackup

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	awaitLiveNode()
void	awaitLiveStatus()
void	crashLiveServer()
void	interrupt()
boolean	isAwaitingFailback()
boolean	isBackupLive()
void	pauseLiveServer()
SimpleString	readNodeId()
void	releaseBackup()
void	startBackup()
ActivateCallback	startLiveNode()

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

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

Methods inherited from class java.lang.Object

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

Field Detail

state

public InVMNodeManager.State state

failoverPause

public long failoverPause

Constructor Detail

InVMNodeManager

public InVMNodeManager(boolean replicatedBackup)

InVMNodeManager

public InVMNodeManager(boolean replicatedBackup,
                       File directory)

Method Detail

awaitLiveNode

public void awaitLiveNode()
                   throws Exception

Specified by:

awaitLiveNode in class NodeManager

Throws:

Exception

awaitLiveStatus

public void awaitLiveStatus()
                     throws Exception

Specified by:

awaitLiveStatus 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

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

interrupt

public void interrupt()

Specified by:

interrupt in class NodeManager

releaseBackup

public void releaseBackup()

Specified by:

releaseBackup in class NodeManager

readNodeId

public SimpleString readNodeId()
                        throws ActiveMQIllegalStateException,
                               IOException

Specified by:

readNodeId in class NodeManager

Throws:

ActiveMQIllegalStateException

IOException