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

Class SharedNothingBackupActivation

java.lang.Object

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

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

All Implemented Interfaces:

Runnable, ReplicationEndpoint.ReplicationEndpointEventListener

public final class SharedNothingBackupActivation
extends Activation
implements ReplicationEndpoint.ReplicationEndpointEventListener

Constructor Summary

Constructors

Constructor	Description
SharedNothingBackupActivation(ActiveMQServerImpl activeMQServer, boolean attemptFailBack, Map<String,Object> activationParams, IOCriticalErrorListener ioCriticalErrorListener, ReplicaPolicy replicaPolicy, NetworkHealthCheck networkHealthCheck)

Method Summary

Modifier and Type	Method	Description
void	close(boolean permanently, boolean restarting)
JournalLoader	createJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer)	create the Journal loader needed for this Activation.
void	failOver(ReplicationPrimaryIsStoppingMessage.PrimaryStopping finalMessage)	Primary has notified this server that it is going to stop.
ReplicationEndpoint	getReplicationEndpoint()
void	haStarted()	called by the ha manager to notify the Activation that HA is now active
void	init()
boolean	isRemoteBackupUpToDate()	Whether a remote backup server was in sync with its primary server.
boolean	isReplicaSync()
void	onPrimaryNodeId(String nodeId)
void	onPrimaryStopping(ReplicationPrimaryIsStoppingMessage.PrimaryStopping finalMessage)
void	onRemoteBackupUpToDate(String nodeId, long ignoredActivationSequence)
void	preStorageClose()	called before the server is closing the journals so the activation can tidy up stuff
void	run()
boolean	waitForBackupSync(long timeout, TimeUnit unit)	Wait for backup synchronization when using synchronization

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

freezeConnections, getActivationChannelHandler, getHAManager, getReplicationManager, postConnectionFreeze, sendPrimaryIsStopping

Methods inherited from class java.lang.Object

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

Constructor Details

SharedNothingBackupActivation

public SharedNothingBackupActivation(ActiveMQServerImpl activeMQServer,
 boolean attemptFailBack,
 Map<String,Object> activationParams,
 IOCriticalErrorListener ioCriticalErrorListener,
 ReplicaPolicy replicaPolicy,
 NetworkHealthCheck networkHealthCheck)

Method Details

init

public void init()
          throws Exception

Throws:

Exception

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

createJournalLoader

public JournalLoader createJournalLoader(PostOffice postOffice,
 PagingManager pagingManager,
 StorageManager storageManager,
 QueueFactory queueFactory,
 NodeManager nodeManager,
 ManagementService managementService,
 GroupingHandler groupingHandler,
 Configuration configuration,
 ActiveMQServer parentServer)
                                  throws ActiveMQException

Description copied from class: Activation

create the Journal loader needed for this Activation.

Overrides:

createJournalLoader in class Activation

Throws:

ActiveMQException

haStarted

public void haStarted()

Description copied from class: Activation

called by the ha manager to notify the Activation that HA is now active

Overrides:

haStarted in class Activation

waitForBackupSync

public boolean waitForBackupSync(long timeout,
 TimeUnit unit)
                          throws InterruptedException

Wait for backup synchronization when using synchronization

Returns:

true if the server was already initialized or if it was initialized within the timeout period, false otherwise.

Throws:

InterruptedException

See Also:

• CountDownLatch.await(long, TimeUnit)

failOver

public void failOver(ReplicationPrimaryIsStoppingMessage.PrimaryStopping finalMessage)

Primary has notified this server that it is going to stop.

getReplicationEndpoint

public ReplicationEndpoint getReplicationEndpoint()

isRemoteBackupUpToDate

public boolean isRemoteBackupUpToDate()

Whether a remote backup server was in sync with its primary server. If it was not in sync, it may not take over the primary's functions.

A local backup server or a primary server should always return true

Returns:

whether the backup is up-to-date, if the server is not a backup it always returns true.

onPrimaryNodeId

public void onPrimaryNodeId(String nodeId)

Specified by:

onPrimaryNodeId in interface ReplicationEndpoint.ReplicationEndpointEventListener

onRemoteBackupUpToDate

public void onRemoteBackupUpToDate(String nodeId,
 long ignoredActivationSequence)

Specified by:

onRemoteBackupUpToDate in interface ReplicationEndpoint.ReplicationEndpointEventListener

onPrimaryStopping

public void onPrimaryStopping(ReplicationPrimaryIsStoppingMessage.PrimaryStopping finalMessage)
                       throws ActiveMQException

Specified by:

onPrimaryStopping in interface ReplicationEndpoint.ReplicationEndpointEventListener

Throws:

ActiveMQException

isReplicaSync

public boolean isReplicaSync()

Overrides:

isReplicaSync in class Activation