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

public final class SharedNothingBackupActivation
extends Activation

Constructor Summary

Constructors

Constructor and Description
SharedNothingBackupActivation(ActiveMQServerImpl activeMQServer, boolean attemptFailBack, Map<String,Object> activationParams, ActiveMQServerImpl.ShutdownOnCriticalErrorListener shutdownOnCriticalIO, ReplicaPolicy replicaPolicy, NetworkHealthCheck networkHealthCheck)

Method Summary

Modifier and Type	Method and 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)
void	failOver(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage) Live has notified this server that it is going to stop.
ReplicationEndpoint	getReplicationEndpoint()
void	haStarted()
void	init()
boolean	isRemoteBackupUpToDate() Whether a remote backup server was in sync with its live server.
void	preStorageClose()
void	remoteFailOver(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage)
void	run()
void	setRemoteBackupUpToDate()
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, sendLiveIsStopping

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedNothingBackupActivation

public SharedNothingBackupActivation(ActiveMQServerImpl activeMQServer,
                                     boolean attemptFailBack,
                                     Map<String,Object> activationParams,
                                     ActiveMQServerImpl.ShutdownOnCriticalErrorListener shutdownOnCriticalIO,
                                     ReplicaPolicy replicaPolicy,
                                     NetworkHealthCheck networkHealthCheck)

Method Detail

init

public void init()
          throws Exception

Throws:

Exception

run

public void run()

close

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

Specified by:

close in class Activation

Throws:

Exception

preStorageClose

public void preStorageClose()
                     throws Exception

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

Overrides:

createJournalLoader in class Activation

Throws:

ActiveMQException

haStarted

public void haStarted()

Overrides:

haStarted in class Activation

waitForBackupSync

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

Wait for backup synchronization when using synchronization

Parameters:

timeout -

unit -

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(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage)

Live 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 live server. If it was not in sync, it may not take over the live's functions.

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

Returns:

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

setRemoteBackupUpToDate

public void setRemoteBackupUpToDate()

remoteFailOver

public void remoteFailOver(ReplicationLiveIsStoppingMessage.LiveStopping finalMessage)
                    throws ActiveMQException

Throws:

ActiveMQException