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:

TransactionFailureCallback

public class LargeMessageTXFailureCallback
extends Object
implements 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<RecordInfo> records, List<RecordInfo> recordsToDelete) To be used to inform about transactions without commit records.

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<RecordInfo> records,
                              List<RecordInfo> recordsToDelete)

Description copied from interface: TransactionFailureCallback

To be used to inform about transactions without commit records. This could be used to remove extra resources associated with the transactions (such as external files received during the transaction)

Specified by:

failedTransaction in interface TransactionFailureCallback