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

Class ReplicationBackupActivation

java.lang.Object

org.apache.activemq.artemis.core.server.impl.Activation

org.apache.activemq.artemis.core.server.impl.ReplicationBackupActivation

All Implemented Interfaces:

Runnable, org.apache.activemq.artemis.lockmanager.DistributedLockManager.UnavailableManagerListener

public final class ReplicationBackupActivation
extends Activation
implements org.apache.activemq.artemis.lockmanager.DistributedLockManager.UnavailableManagerListener

This activation can be used by a primary while trying to fail-back ie failback == true or by a natural-born backup ie failback == false.

Constructor Summary

Constructors

Constructor	Description
ReplicationBackupActivation(ActiveMQServerImpl activeMQServer, org.apache.activemq.artemis.lockmanager.DistributedLockManager distributedManager, ReplicationBackupPolicy policy)

Method Summary

Modifier and Type	Method	Description
void	close(boolean permanently, boolean restarting)
org.apache.activemq.artemis.lockmanager.DistributedLockManager	getDistributedManager()	used for testing purposes.
ReplicationEndpoint	getReplicationEndpoint()
boolean	isReplicaSync()
void	onUnavailableManagerEvent()
void	preStorageClose()	called before the server is closing the journals so the activation can tidy up stuff
void	run()
void	spyReplicationEndpointCreation(Consumer<ReplicationEndpoint> onReplicationEndpointCreation)	This must be used just for testing purposes.

Methods inherited from class org.apache.activemq.artemis.core.server.impl.Activation

createJournalLoader, freezeConnections, getActivationChannelHandler, getHAManager, getReplicationManager, haStarted, postConnectionFreeze, sendPrimaryIsStopping

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationBackupActivation

public ReplicationBackupActivation(ActiveMQServerImpl activeMQServer,
 org.apache.activemq.artemis.lockmanager.DistributedLockManager distributedManager,
 ReplicationBackupPolicy policy)

Method Details

getDistributedManager

public org.apache.activemq.artemis.lockmanager.DistributedLockManager getDistributedManager()

used for testing purposes.

onUnavailableManagerEvent

public void onUnavailableManagerEvent()

Specified by:

onUnavailableManagerEvent in interface org.apache.activemq.artemis.lockmanager.DistributedLockManager.UnavailableManagerListener

run

public void run()

Specified by:

run in interface Runnable

close

public void close(boolean permanently,
 boolean restarting)
           throws Exception

Specified by:

close in class Activation

Throws:

Exception

preStorageClose

public void preStorageClose()
                     throws Exception

Description copied from class: Activation

called before the server is closing the journals so the activation can tidy up stuff

Overrides:

preStorageClose in class Activation

Throws:

Exception

isReplicaSync

public boolean isReplicaSync()

Overrides:

isReplicaSync in class Activation

getReplicationEndpoint

public ReplicationEndpoint getReplicationEndpoint()

spyReplicationEndpointCreation

public void spyReplicationEndpointCreation(Consumer<ReplicationEndpoint> onReplicationEndpointCreation)

This must be used just for testing purposes.