org.apache.activemq.artemis.core.server.cluster.ha

Class ColocatedHAManager

java.lang.Object

org.apache.activemq.artemis.core.server.cluster.ha.ColocatedHAManager

All Implemented Interfaces:

org.apache.activemq.artemis.core.server.ActiveMQComponent, HAManager

public class ColocatedHAManager
extends Object
implements HAManager

Constructor Summary

Constructors

Constructor and Description
ColocatedHAManager(ColocatedPolicy haPolicy, ActiveMQServer activeMQServer)

Method Summary

Modifier and Type	Method and Description
boolean	activateBackup(int backupSize, String journalDirectory, String bindingsDirectory, String largeMessagesDirectory, String pagingDirectory, org.apache.activemq.artemis.api.core.SimpleString nodeID)
Map<String,ActiveMQServer>	getBackupServers() return the current backup servers
boolean	isStarted()
boolean	requestBackup(org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> connectorPair, int backupSize, boolean replicated) send a request to a live server to start a backup for us
void	start() starts the HA manager.
void	stop() stop any backups

Methods inherited from class java.lang.Object

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

Constructor Detail

ColocatedHAManager

public ColocatedHAManager(ColocatedPolicy haPolicy,
                          ActiveMQServer activeMQServer)

Method Detail

start

public void start()

starts the HA manager.

Specified by:

start in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

stop

public void stop()

stop any backups

Specified by:

stop in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

isStarted

public boolean isStarted()

Specified by:

isStarted in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

activateBackup

public boolean activateBackup(int backupSize,
                              String journalDirectory,
                              String bindingsDirectory,
                              String largeMessagesDirectory,
                              String pagingDirectory,
                              org.apache.activemq.artemis.api.core.SimpleString nodeID)
                       throws Exception

Throws:

Exception

getBackupServers

public Map<String,ActiveMQServer> getBackupServers()

return the current backup servers

Specified by:

getBackupServers in interface HAManager

Returns:

the backups

requestBackup

public boolean requestBackup(org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> connectorPair,
                             int backupSize,
                             boolean replicated)
                      throws Exception

send a request to a live server to start a backup for us

Parameters:

connectorPair - the connector for the node to request a backup from

backupSize - the current size of the requested nodes backups

replicated -

Returns:

true if the request wa successful.

Throws:

Exception