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.

Field Summary

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

channel, FIRST_TIME_START, replicatedBackup

Method Summary

Modifier and Type	Method and Description
void	awaitLiveNode()
void	awaitLiveStatus()
void	crashLiveServer()
protected void	finalize()
void	interrupt()
boolean	isAwaitingFailback()
boolean	isBackupLive()
void	pauseLiveServer()
SimpleString	readNodeId()
void	releaseBackup()
void	start()
void	startBackup()
ActivateCallback	startLiveNode()
void	stop()
void	stopBackup()
static JdbcNodeManager	with(DatabaseStorageConfiguration configuration, ScheduledExecutorService scheduledExecutorService, ExecutorFactory executorFactory, IOCriticalErrorListener ioCriticalErrorListener)

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

createNodeId, getNodeId, getUUID, isStarted, newFile, setNodeID, setUpServerLockFile, setUUID

Methods inherited from class java.lang.Object

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

Method Detail

with

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

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 Exception

Specified by:

isAwaitingFailback in class NodeManager

Throws:

Exception

isBackupLive

public boolean isBackupLive()
                     throws Exception

Specified by:

isBackupLive in class NodeManager

Throws:

Exception

stopBackup

public void stopBackup()
                throws Exception

Overrides:

stopBackup in class NodeManager

Throws:

Exception

interrupt

public void interrupt()

Specified by:

interrupt in class NodeManager

releaseBackup

public void releaseBackup()
                   throws Exception

Specified by:

releaseBackup in class NodeManager

Throws:

Exception

awaitLiveNode

public void awaitLiveNode()
                   throws Exception

Specified by:

awaitLiveNode 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

awaitLiveStatus

public void awaitLiveStatus()

Specified by:

awaitLiveStatus in class NodeManager

readNodeId

public SimpleString readNodeId()

Specified by:

readNodeId in class NodeManager