org.hornetq.core.journal.impl.dataformat

Class JournalCompleteRecordTX

java.lang.Object

org.hornetq.core.journal.impl.dataformat.JournalInternalRecord

org.hornetq.core.journal.impl.dataformat.JournalCompleteRecordTX

All Implemented Interfaces:

EncodingSupport

public class JournalCompleteRecordTX
extends JournalInternalRecord

A transaction record (Commit or Prepare), will hold the number of elements the transaction has on each file.

For example, a transaction was spread along 3 journal files with 10 pendingTransactions on each file. (What could happen if there are too many pendingTransactions, or if an user event delayed pendingTransactions to come in time to a single file).

The element-summary will then have

FileID1, 10

FileID2, 10

FileID3, 10

During the load, the transaction needs to have 30 pendingTransactions spread across the files as originally written.

If for any reason there are missing pendingTransactions, that means the transaction was not completed and we should ignore the whole transaction

We can't just use a global counter as reclaiming could delete files after the transaction was successfully committed. That also means not having a whole file on journal-reload doesn't mean we have to invalidate the transaction

Author:

Clebert Suconic

Field Summary

Fields

Modifier and Type	Field and Description
long	txID

Fields inherited from class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord

compactCount, fileID

Constructor Summary

Constructors

Constructor and Description
JournalCompleteRecordTX(boolean isCommit, long txID, EncodingSupport transactionData)

Method Summary

Methods

Modifier and Type	Method and Description
void	encode(HornetQBuffer buffer)
int	getEncodeSize()
int	getNumberOfRecords()
void	setNumberOfRecords(int records)

Methods inherited from class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord

decode, getCompactCount, getFileID, setCompactCount, setFileID

Methods inherited from class java.lang.Object

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

Field Detail

txID

public final long txID

Constructor Detail

JournalCompleteRecordTX

public JournalCompleteRecordTX(boolean isCommit,
                       long txID,
                       EncodingSupport transactionData)

Method Detail

encode

public void encode(HornetQBuffer buffer)

setNumberOfRecords

public void setNumberOfRecords(int records)

Overrides:

setNumberOfRecords in class JournalInternalRecord

getNumberOfRecords

public int getNumberOfRecords()

Overrides:

getNumberOfRecords in class JournalInternalRecord

getEncodeSize

public int getEncodeSize()

Specified by:

getEncodeSize in interface EncodingSupport

Specified by:

getEncodeSize in class JournalInternalRecord