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

Class NodeManager

java.lang.Object

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

All Implemented Interfaces:

ActiveMQComponent

Direct Known Subclasses:

FileBasedNodeManager, JdbcNodeManager

public abstract class NodeManager
extends Object
implements ActiveMQComponent

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	NodeManager.LockListener
static final class	NodeManager.NodeManagerException

Field Summary

Fields

Modifier and Type	Field	Description
protected long	nodeActivationSequence
protected final Object	nodeIDGuard
static final long	NULL_NODE_ACTIVATION_SEQUENCE
protected final boolean	replicatedBackup

Constructor Summary

Constructors

Constructor	Description
NodeManager(boolean replicatedBackup)

Method Summary

Modifier and Type	Method	Description
abstract void	awaitActiveStatus()
abstract void	awaitPrimaryNode()
protected void	checkStarted()
abstract void	crashPrimaryServer()
long	getNodeActivationSequence()
SimpleString	getNodeId()
UUID	getUUID()
abstract void	interrupt()
abstract boolean	isAwaitingFailback()
abstract boolean	isBackupActive()
boolean	isStarted()
protected void	notifyLostLock()
abstract void	pausePrimaryServer()
long	readNodeActivationSequence()
abstract SimpleString	readNodeId()
void	registerLockListener(NodeManager.LockListener lockListener)
abstract void	releaseBackup()
void	setNodeActivationSequence(long sequence)
void	setNodeID(String nodeID)	Sets the nodeID.
protected void	setUUID(UUID generateUUID)
void	start()
abstract void	startBackup()
abstract ActivateCallback	startPrimaryNode()
void	stop()
void	stopBackup()
void	unregisterLockListener(NodeManager.LockListener lockListener)
void	writeNodeActivationSequence(long version)

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

replicatedBackup

protected final boolean replicatedBackup

nodeIDGuard

protected final Object nodeIDGuard

NULL_NODE_ACTIVATION_SEQUENCE

public static final long NULL_NODE_ACTIVATION_SEQUENCE

See Also:

• Constant Field Values

nodeActivationSequence

protected long nodeActivationSequence

Constructor Details

NodeManager

public NodeManager(boolean replicatedBackup)

Method Details

awaitPrimaryNode

public abstract void awaitPrimaryNode()
                               throws NodeManager.NodeManagerException,
InterruptedException

Throws:

NodeManager.NodeManagerException

InterruptedException

awaitActiveStatus

public abstract void awaitActiveStatus()
                                throws NodeManager.NodeManagerException,
InterruptedException

Throws:

NodeManager.NodeManagerException

InterruptedException

startBackup

public abstract void startBackup()
                          throws NodeManager.NodeManagerException,
InterruptedException

Throws:

NodeManager.NodeManagerException

InterruptedException

startPrimaryNode

public abstract ActivateCallback startPrimaryNode()
                                           throws NodeManager.NodeManagerException,
InterruptedException

Throws:

NodeManager.NodeManagerException

InterruptedException

pausePrimaryServer

public abstract void pausePrimaryServer()
                                 throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

crashPrimaryServer

public abstract void crashPrimaryServer()
                                 throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

releaseBackup

public abstract void releaseBackup()
                            throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

getNodeId

public SimpleString getNodeId()

readNodeActivationSequence

public long readNodeActivationSequence()
                                throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

writeNodeActivationSequence

public void writeNodeActivationSequence(long version)
                                 throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

readNodeId

public abstract SimpleString readNodeId()
                                 throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

getNodeActivationSequence

public long getNodeActivationSequence()

setNodeActivationSequence

public void setNodeActivationSequence(long sequence)

getUUID

public UUID getUUID()

setNodeID

public void setNodeID(String nodeID)

Sets the nodeID.

Only used by replicating backups.

setUUID

protected void setUUID(UUID generateUUID)

isAwaitingFailback

public abstract boolean isAwaitingFailback()
                                    throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

isBackupActive

public abstract boolean isBackupActive()
                                throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

interrupt

public abstract void interrupt()

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Throws:

Exception

stopBackup

public void stopBackup()
                throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

checkStarted

protected void checkStarted()

notifyLostLock

protected void notifyLostLock()

registerLockListener

public void registerLockListener(NodeManager.LockListener lockListener)

unregisterLockListener

public void unregisterLockListener(NodeManager.LockListener lockListener)