org.apache.activemq.artemis.core.persistence.impl.journal

Class LargeMessageTXFailureCallback

java.lang.Object

org.apache.activemq.artemis.core.persistence.impl.journal.LargeMessageTXFailureCallback

All Implemented Interfaces:

org.apache.activemq.artemis.core.journal.TransactionFailureCallback

public class LargeMessageTXFailureCallback
extends Object
implements org.apache.activemq.artemis.core.journal.TransactionFailureCallback

Constructor Summary

Constructors

Constructor and Description
LargeMessageTXFailureCallback(AbstractJournalStorageManager journalStorageManager, Map<Long,ServerMessage> messages)

Method Summary

Modifier and Type	Method and Description
void	failedTransaction(long transactionID, List<org.apache.activemq.artemis.core.journal.RecordInfo> records, List<org.apache.activemq.artemis.core.journal.RecordInfo> recordsToDelete)

Methods inherited from class java.lang.Object

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

Constructor Detail

LargeMessageTXFailureCallback

public LargeMessageTXFailureCallback(AbstractJournalStorageManager journalStorageManager,
                                     Map<Long,ServerMessage> messages)

Method Detail

failedTransaction

public void failedTransaction(long transactionID,
                              List<org.apache.activemq.artemis.core.journal.RecordInfo> records,
                              List<org.apache.activemq.artemis.core.journal.RecordInfo> recordsToDelete)

Specified by:

failedTransaction in interface org.apache.activemq.artemis.core.journal.TransactionFailureCallback