Package 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:

ActiveMQComponent, HAManager

public class ColocatedHAManager
extends Object
implements HAManager

Constructor Summary

Constructors

Constructor	Description
ColocatedHAManager(ColocatedPolicy haPolicy, ActiveMQServer activeMQServer)

Method Summary

Modifier and Type	Method	Description
boolean	activateBackup(int backupSize, String journalDirectory, String bindingsDirectory, String largeMessagesDirectory, String pagingDirectory, SimpleString nodeID)
Map<String,ActiveMQServer>	getBackupServers()	return the current backup servers
boolean	isStarted()
boolean	requestBackup(Pair<TransportConfiguration,TransportConfiguration> connectorPair, int backupSize, boolean replicated)	send a request to a primary server to start a backup for us
void	start()
void	stop()

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

Constructor Details

ColocatedHAManager

public ColocatedHAManager(ColocatedPolicy haPolicy,
 ActiveMQServer activeMQServer)

Method Details

start

public void start()

Specified by:

start in interface ActiveMQComponent

stop

public void stop()

Specified by:

stop in interface ActiveMQComponent

isStarted

public boolean isStarted()

Specified by:

isStarted in interface ActiveMQComponent

activateBackup

public boolean activateBackup(int backupSize,
 String journalDirectory,
 String bindingsDirectory,
 String largeMessagesDirectory,
 String pagingDirectory,
 SimpleString nodeID)
                       throws Exception

Throws:

Exception

getBackupServers

public Map<String,ActiveMQServer> getBackupServers()

Description copied from interface: HAManager

return the current backup servers

Specified by:

getBackupServers in interface HAManager

Returns:

the backups

requestBackup

public boolean requestBackup(Pair<TransportConfiguration,TransportConfiguration> connectorPair,
 int backupSize,
 boolean replicated)
                      throws Exception

send a request to a primary 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

Returns:

true if the request wa successful

Throws:

Exception