org.hornetq.core.journal.impl

Class JournalTransaction

java.lang.Object

org.hornetq.core.journal.impl.JournalTransaction

public class JournalTransaction
extends Object

A JournalTransaction

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
JournalTransaction(long id, JournalRecordProvider journal)

Method Summary

Methods

Modifier and Type	Method and Description
void	addNegative(JournalFile file, long id)
void	addPositive(JournalFile file, long id, int size)
void	clear()
void	commit(JournalFile file) The caller of this method needs to guarantee appendLock.lock at the journal.
void	fillNumberOfRecords(JournalFile currentFile, JournalInternalRecord data)
void	forget() Used by load, when the transaction was not loaded correctly
TransactionCallback	getCallback(JournalFile file)
int	getCounter(JournalFile file)
long	getId()
long[]	getPositiveArray()
void	incCounter(JournalFile file)
void	merge(JournalTransaction other) This is used to merge transactions from compacting
void	prepare(JournalFile file) The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
void	replaceRecordProvider(JournalRecordProvider provider)
void	rollback(JournalFile file) The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
void	setCompacting()
String	toString()
void	waitCallbacks()
void	waitCompletion() Wait completion at the latest file only

Methods inherited from class java.lang.Object

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

Constructor Detail

JournalTransaction

public JournalTransaction(long id,
                  JournalRecordProvider journal)

Method Detail

replaceRecordProvider

public void replaceRecordProvider(JournalRecordProvider provider)

getId

public long getId()

Returns:

the id

getCounter

public int getCounter(JournalFile file)

incCounter

public void incCounter(JournalFile file)

getPositiveArray

public long[] getPositiveArray()

setCompacting

public void setCompacting()

merge

public void merge(JournalTransaction other)

This is used to merge transactions from compacting

clear

public void clear()

fillNumberOfRecords

public void fillNumberOfRecords(JournalFile currentFile,
                       JournalInternalRecord data)

Parameters:

currentFile -

data -

getCallback

public TransactionCallback getCallback(JournalFile file)
                                throws Exception

Throws:

Exception

addPositive

public void addPositive(JournalFile file,
               long id,
               int size)

addNegative

public void addNegative(JournalFile file,
               long id)

commit

public void commit(JournalFile file)

The caller of this method needs to guarantee appendLock.lock at the journal. (unless this is being called from load what is a single thread process).

waitCallbacks

public void waitCallbacks()
                   throws Exception

Throws:

Exception

waitCompletion

public void waitCompletion()
                    throws Exception

Wait completion at the latest file only

Throws:

Exception

rollback

public void rollback(JournalFile file)

The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context. or else potFilesMap could be affected

prepare

public void prepare(JournalFile file)

The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context. or else potFilesMap could be affected

forget

public void forget()

Used by load, when the transaction was not loaded correctly

toString

public String toString()

Overrides:

toString in class Object