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

Class BackupRecoveryJournalLoader

java.lang.Object

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

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

All Implemented Interfaces:

JournalLoader

public class BackupRecoveryJournalLoader
extends PostOfficeJournalLoader

Instead of loading into its own post office this will use its parent server (the active server) and load into that. Since the server is already running we have to make sure we don't route any message that may subsequently get deleted or acked.

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.server.impl.PostOfficeJournalLoader

nodeManager, pagingManager, postOffice

Constructor Summary

Constructors

Constructor	Description
BackupRecoveryJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, ActiveMQServer parentServer, ServerLocatorInternal locator, ClusterController clusterController)

Method Summary

Modifier and Type	Method	Description
void	cleanUp()
void	handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	handleGroupingBindings(List<GroupingInfo> groupingInfos)
void	postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)

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

handleAddMessage, handleNoMessageReferences, handlePreparedAcknowledge, handlePreparedSendMessage, handlePreparedTransaction, initAddresses, initQueues, recoverPendingPageCounters

Methods inherited from class java.lang.Object

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

Constructor Details

BackupRecoveryJournalLoader

public BackupRecoveryJournalLoader(PostOffice postOffice,
 PagingManager pagingManager,
 StorageManager storageManager,
 QueueFactory queueFactory,
 NodeManager nodeManager,
 ManagementService managementService,
 GroupingHandler groupingHandler,
 Configuration configuration,
 ActiveMQServer parentServer,
 ServerLocatorInternal locator,
 ClusterController clusterController)

Method Details

handleGroupingBindings

public void handleGroupingBindings(List<GroupingInfo> groupingInfos)

Specified by:

handleGroupingBindings in interface JournalLoader

Overrides:

handleGroupingBindings in class PostOfficeJournalLoader

handleDuplicateIds

public void handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
                        throws Exception

Specified by:

handleDuplicateIds in interface JournalLoader

Overrides:

handleDuplicateIds in class PostOfficeJournalLoader

Throws:

Exception

postLoad

public void postLoad(Journal messageJournal,
 ResourceManager resourceManager,
 Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
              throws Exception

Specified by:

postLoad in interface JournalLoader

Overrides:

postLoad in class PostOfficeJournalLoader

Throws:

Exception

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface JournalLoader

Overrides:

cleanUp in class PostOfficeJournalLoader