public interface JournalLoader
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) |
void |
recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter) |
void initQueues(Map<Long,QueueBindingInfo> queueBindingInfosMap, List<QueueBindingInfo> queueBindingInfos) throws Exception
Exception
void handleAddMessage(Map<Long,Map<Long,AddMessageRecord>> queueMap) throws Exception
Exception
void handleNoMessageReferences(Map<Long,ServerMessage> messages)
void handleGroupingBindings(List<GroupingInfo> groupingInfos)
void handleDuplicateIds(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap) throws Exception
Exception
void handlePreparedSendMessage(ServerMessage message, Transaction tx, long queueID) throws Exception
Exception
void handlePreparedAcknowledge(long messageID, List<MessageReference> referencesToAck, long queueID) throws Exception
Exception
void handlePreparedTransaction(Transaction tx, List<MessageReference> referencesToAck, Xid xid, ResourceManager resourceManager) throws Exception
Exception
void recoverPendingPageCounters(List<PageCountPending> pendingNonTXPageCounter) throws Exception
Exception
void cleanUp()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.