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

Class SharedStoreBackupActivation

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public final class SharedStoreBackupActivation
extends Activation

Constructor Summary

Constructors

Constructor	Description
SharedStoreBackupActivation(ActiveMQServerImpl server, SharedStoreBackupPolicy sharedStoreBackupPolicy, IOCriticalErrorListener ioCriticalErrorListener)

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	run()

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

freezeConnections, getActivationChannelHandler, getHAManager, getReplicationManager, haStarted, isReplicaSync, postConnectionFreeze, preStorageClose, sendPrimaryIsStopping

Methods inherited from class java.lang.Object

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

Constructor Details

SharedStoreBackupActivation

public SharedStoreBackupActivation(ActiveMQServerImpl server,
 SharedStoreBackupPolicy sharedStoreBackupPolicy,
 IOCriticalErrorListener ioCriticalErrorListener)

Method Details

run

public void run()

close

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

Specified by:

close 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