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 and Description
static interface	NodeManager.LockListener
static class	NodeManager.NodeManagerException

Field Summary

Fields

Modifier and Type	Field and Description
protected Object	nodeIDGuard
protected boolean	replicatedBackup

Constructor Summary

Constructors

Constructor and Description
NodeManager(boolean replicatedBackup)

Method Summary

Modifier and Type	Method and Description
abstract void	awaitLiveNode()
abstract void	awaitLiveStatus()
protected void	checkStarted()
abstract void	crashLiveServer()
SimpleString	getNodeId()
UUID	getUUID()
abstract void	interrupt()
abstract boolean	isAwaitingFailback()
abstract boolean	isBackupLive()
boolean	isStarted()
protected void	notifyLostLock()
abstract void	pauseLiveServer()
abstract SimpleString	readNodeId()
void	registerLockListener(NodeManager.LockListener lockListener)
abstract void	releaseBackup()
void	setNodeID(String nodeID) Sets the nodeID.
protected void	setUUID(UUID generateUUID)
void	start()
abstract void	startBackup()
abstract ActivateCallback	startLiveNode()
void	stop()
void	stopBackup()
void	unregisterLockListener(NodeManager.LockListener lockListener)

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

replicatedBackup

protected final boolean replicatedBackup

nodeIDGuard

protected final Object nodeIDGuard

Constructor Detail

NodeManager

public NodeManager(boolean replicatedBackup)

Method Detail

awaitLiveNode

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

Throws:

NodeManager.NodeManagerException

InterruptedException

awaitLiveStatus

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

Throws:

NodeManager.NodeManagerException

InterruptedException

startBackup

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

Throws:

NodeManager.NodeManagerException

InterruptedException

startLiveNode

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

Throws:

NodeManager.NodeManagerException

InterruptedException

pauseLiveServer

public abstract void pauseLiveServer()
                              throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

crashLiveServer

public abstract void crashLiveServer()
                              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()

readNodeId

public abstract SimpleString readNodeId()
                                 throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

getUUID

public UUID getUUID()

setNodeID

public void setNodeID(String nodeID)

Sets the nodeID.

Only used by replicating backups.

Parameters:

nodeID -

setUUID

protected void setUUID(UUID generateUUID)

Parameters:

generateUUID -

isAwaitingFailback

public abstract boolean isAwaitingFailback()
                                    throws NodeManager.NodeManagerException

Throws:

NodeManager.NodeManagerException

isBackupLive

public abstract boolean isBackupLive()
                              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)