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

Class PostOfficeJournalLoader

java.lang.Object

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

All Implemented Interfaces:

JournalLoader

Direct Known Subclasses:

BackupRecoveryJournalLoader

public class PostOfficeJournalLoader
extends Object
implements JournalLoader

Field Summary

Fields

Modifier and Type	Field and Description
protected NodeManager	nodeManager
protected PagingManager	pagingManager
protected PostOffice	postOffice

Constructor Summary

Constructors

Constructor and Description
PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration)
PostOfficeJournalLoader(PostOffice postOffice, PagingManager pagingManager, StorageManager storageManager, QueueFactory queueFactory, NodeManager nodeManager, ManagementService managementService, GroupingHandler groupingHandler, Configuration configuration, Map<Long,Queue> queues)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
void	handleAddMessage(Map<Long,Map<Long,AddMessageRecord>> queueMap)
void	handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	handleGroupingBindings(List<GroupingInfo> groupingInfos)
void	handleNoMessageReferences(Map<Long,ServerMessage> messages)
void	handlePreparedAcknowledge(long messageID, List<MessageReference> referencesToAck, long queueID)
void	handlePreparedSendMessage(ServerMessage message, Transaction tx, long queueID)
void	handlePreparedTransaction(Transaction tx, List<MessageReference> referencesToAck, Xid xid, ResourceManager resourceManager)
void	initQueues(Map<Long,QueueBindingInfo> queueBindingInfosMap, List<QueueBindingInfo> queueBindingInfos)
void	postLoad(Journal messageJournal, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap)
void	recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter) This method will recover the counters after failures making sure the page counter doesn't get out of sync

Methods inherited from class java.lang.Object

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

Field Detail

postOffice

protected final PostOffice postOffice

pagingManager

protected final PagingManager pagingManager

nodeManager

protected final NodeManager nodeManager

Constructor Detail

PostOfficeJournalLoader

public PostOfficeJournalLoader(PostOffice postOffice,
                               PagingManager pagingManager,
                               StorageManager storageManager,
                               QueueFactory queueFactory,
                               NodeManager nodeManager,
                               ManagementService managementService,
                               GroupingHandler groupingHandler,
                               Configuration configuration)

PostOfficeJournalLoader

public PostOfficeJournalLoader(PostOffice postOffice,
                               PagingManager pagingManager,
                               StorageManager storageManager,
                               QueueFactory queueFactory,
                               NodeManager nodeManager,
                               ManagementService managementService,
                               GroupingHandler groupingHandler,
                               Configuration configuration,
                               Map<Long,Queue> queues)

Method Detail

initQueues

public void initQueues(Map<Long,QueueBindingInfo> queueBindingInfosMap,
                       List<QueueBindingInfo> queueBindingInfos)
                throws Exception

Specified by:

initQueues in interface JournalLoader

Throws:

Exception

handleAddMessage

public void handleAddMessage(Map<Long,Map<Long,AddMessageRecord>> queueMap)
                      throws Exception

Specified by:

handleAddMessage in interface JournalLoader

Throws:

Exception

handleNoMessageReferences

public void handleNoMessageReferences(Map<Long,ServerMessage> messages)

Specified by:

handleNoMessageReferences in interface JournalLoader

handleGroupingBindings

public void handleGroupingBindings(List<GroupingInfo> groupingInfos)

Specified by:

handleGroupingBindings in interface JournalLoader

handleDuplicateIds

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

Specified by:

handleDuplicateIds in interface JournalLoader

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

Throws:

Exception

handlePreparedSendMessage

public void handlePreparedSendMessage(ServerMessage message,
                                      Transaction tx,
                                      long queueID)
                               throws Exception

Specified by:

handlePreparedSendMessage in interface JournalLoader

Throws:

Exception

handlePreparedAcknowledge

public void handlePreparedAcknowledge(long messageID,
                                      List<MessageReference> referencesToAck,
                                      long queueID)
                               throws Exception

Specified by:

handlePreparedAcknowledge in interface JournalLoader

Throws:

Exception

handlePreparedTransaction

public void handlePreparedTransaction(Transaction tx,
                                      List<MessageReference> referencesToAck,
                                      Xid xid,
                                      ResourceManager resourceManager)
                               throws Exception

Specified by:

handlePreparedTransaction in interface JournalLoader

Throws:

Exception

recoverPendingPageCounters

public void recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter)
                                throws Exception

This method will recover the counters after failures making sure the page counter doesn't get out of sync

Specified by:

recoverPendingPageCounters in interface JournalLoader

Parameters:

pendingNonTXPageCounter -

Throws:

Exception

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface JournalLoader