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
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 TypeMethodDescriptionvoidvoidvoidprotected voidfinalize()voidbooleanbooleanprotected voidvoidvoidvoidstart()voidvoidstop()static JdbcNodeManagerwith(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, writeNodeActivationSequenceMethods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods 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:
notifyLostLockin classNodeManager
-
start
- Specified by:
startin interfaceActiveMQComponent- Overrides:
startin classNodeManager- Throws:
Exception
-
stop
- Specified by:
stopin interfaceActiveMQComponent- Overrides:
stopin classNodeManager- Throws:
Exception
-
finalize
-
isAwaitingFailback
- Specified by:
isAwaitingFailbackin classNodeManager- Throws:
NodeManager.NodeManagerException
-
isBackupActive
- Specified by:
isBackupActivein classNodeManager- Throws:
NodeManager.NodeManagerException
-
interrupt
public void interrupt()- Specified by:
interruptin classNodeManager
-
releaseBackup
- Specified by:
releaseBackupin classNodeManager- Throws:
NodeManager.NodeManagerException
-
awaitPrimaryNode
- Specified by:
awaitPrimaryNodein classNodeManager- Throws:
NodeManager.NodeManagerExceptionInterruptedException
-
startBackup
- Specified by:
startBackupin classNodeManager- Throws:
NodeManager.NodeManagerExceptionInterruptedException
-
startPrimaryNode
public ActivateCallback startPrimaryNode() throws NodeManager.NodeManagerException, InterruptedException- Specified by:
startPrimaryNodein classNodeManager- Throws:
NodeManager.NodeManagerExceptionInterruptedException
-
pausePrimaryServer
- Specified by:
pausePrimaryServerin classNodeManager- Throws:
NodeManager.NodeManagerException
-
crashPrimaryServer
- Specified by:
crashPrimaryServerin classNodeManager- Throws:
NodeManager.NodeManagerException
-
awaitActiveStatus
public void awaitActiveStatus()- Specified by:
awaitActiveStatusin classNodeManager
-
readNodeId
- Specified by:
readNodeIdin classNodeManager
-