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

Class JdbcNodeManager

java.lang.Object

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

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

All Implemented Interfaces:

ActiveMQComponent

public final class JdbcNodeManager
extends NodeManager

JDBC implementation of NodeManager.

Nested Class Summary

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

NodeManager.LockListener, NodeManager.NodeManagerException

Field Summary

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

nodeActivationSequence, nodeIDGuard, NULL_NODE_ACTIVATION_SEQUENCE, replicatedBackup

Method Summary

Modifier and Type	Method	Description
void	awaitActiveStatus()
void	awaitPrimaryNode()
void	crashPrimaryServer()
protected void	finalize()
void	interrupt()
boolean	isAwaitingFailback()
boolean	isBackupActive()
protected void	notifyLostLock()
void	pausePrimaryServer()
SimpleString	readNodeId()
void	releaseBackup()
void	start()
void	startBackup()
ActivateCallback	startPrimaryNode()
void	stop()
static JdbcNodeManager	with(DatabaseStorageConfiguration configuration, ScheduledExecutorService scheduledExecutorService, ExecutorFactory executorFactory)

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

checkStarted, getNodeActivationSequence, getNodeId, getUUID, isStarted, readNodeActivationSequence, registerLockListener, setNodeActivationSequence, setNodeID, setUUID, stopBackup, unregisterLockListener, writeNodeActivationSequence

Methods inherited from class java.lang.Object

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

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

asyncStop

Method Details

with

public static JdbcNodeManager with(DatabaseStorageConfiguration configuration,
 ScheduledExecutorService scheduledExecutorService,
 ExecutorFactory executorFactory)

notifyLostLock

protected void notifyLostLock()

Overrides:

notifyLostLock in class NodeManager

start

public void start()
           throws Exception

Specified by:

start in interface ActiveMQComponent

Overrides:

start in class NodeManager

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface ActiveMQComponent

Overrides:

stop in class NodeManager

Throws:

Exception

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

isAwaitingFailback

public boolean isAwaitingFailback()
                           throws NodeManager.NodeManagerException

Specified by:

isAwaitingFailback in class NodeManager

Throws:

NodeManager.NodeManagerException

isBackupActive

public boolean isBackupActive()
                       throws NodeManager.NodeManagerException

Specified by:

isBackupActive in class NodeManager

Throws:

NodeManager.NodeManagerException

interrupt

public void interrupt()

Specified by:

interrupt in class NodeManager

releaseBackup

public void releaseBackup()
                   throws NodeManager.NodeManagerException

Specified by:

releaseBackup in class NodeManager

Throws:

NodeManager.NodeManagerException

awaitPrimaryNode

public void awaitPrimaryNode()
                      throws NodeManager.NodeManagerException,
InterruptedException

Specified by:

awaitPrimaryNode in class NodeManager

Throws:

NodeManager.NodeManagerException

InterruptedException

startBackup

public void startBackup()
                 throws NodeManager.NodeManagerException,
InterruptedException

Specified by:

startBackup in class NodeManager

Throws:

NodeManager.NodeManagerException

InterruptedException

startPrimaryNode

public ActivateCallback startPrimaryNode()
                                  throws NodeManager.NodeManagerException,
InterruptedException

Specified by:

startPrimaryNode in class NodeManager

Throws:

NodeManager.NodeManagerException

InterruptedException

pausePrimaryServer

public void pausePrimaryServer()
                        throws NodeManager.NodeManagerException

Specified by:

pausePrimaryServer in class NodeManager

Throws:

NodeManager.NodeManagerException

crashPrimaryServer

public void crashPrimaryServer()
                        throws NodeManager.NodeManagerException

Specified by:

crashPrimaryServer in class NodeManager

Throws:

NodeManager.NodeManagerException

awaitActiveStatus

public void awaitActiveStatus()

Specified by:

awaitActiveStatus in class NodeManager

readNodeId

public SimpleString readNodeId()

Specified by:

readNodeId in class NodeManager