org.jboss.messaging.core.journal
Interface Journal

All Superinterfaces:

MessagingComponent

All Known Subinterfaces:

TestableJournal

All Known Implementing Classes:

JournalImpl

public interface Journal
extends MessagingComponent

A Journal

Author:

Tim Fox, Clebert Suconic

Method Summary

void	appendAddRecord(long id, byte recordType, byte[] record)
void	appendAddRecord(long id, byte recordType, EncodingSupport record)
void	appendAddRecordTransactional(long txID, byte recordType, long id, byte[] record)
void	appendAddRecordTransactional(long txID, byte recordType, long id, EncodingSupport record)
void	appendCommitRecord(long txID)
void	appendDeleteRecord(long id)
void	appendDeleteRecordTransactional(long txID, long id)
void	appendPrepareRecord(long txID)
void	appendRollbackRecord(long txID)
void	appendUpdateRecord(long id, byte recordType, byte[] record)
void	appendUpdateRecordTransactional(long txID, byte recordType, long id, byte[] record)
int	getAlignment()
long	getTransactionID()
long	load(java.util.List<RecordInfo> committedRecords, java.util.List<PreparedTransactionInfo> preparedTransactions)
void	startReclaimer()
void	stopReclaimer()

Methods inherited from interface org.jboss.messaging.core.server.MessagingComponent

start, stop

Method Detail

appendAddRecord

void appendAddRecord(long id,
                     byte recordType,
                     EncodingSupport record)
                     throws java.lang.Exception

Throws:

java.lang.Exception

appendAddRecord

void appendAddRecord(long id,
                     byte recordType,
                     byte[] record)
                     throws java.lang.Exception

Throws:

java.lang.Exception

appendUpdateRecord

void appendUpdateRecord(long id,
                        byte recordType,
                        byte[] record)
                        throws java.lang.Exception

Throws:

java.lang.Exception

appendDeleteRecord

void appendDeleteRecord(long id)
                        throws java.lang.Exception

Throws:

java.lang.Exception

getTransactionID

long getTransactionID()

appendAddRecordTransactional

void appendAddRecordTransactional(long txID,
                                  byte recordType,
                                  long id,
                                  EncodingSupport record)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

appendAddRecordTransactional

void appendAddRecordTransactional(long txID,
                                  byte recordType,
                                  long id,
                                  byte[] record)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

appendUpdateRecordTransactional

void appendUpdateRecordTransactional(long txID,
                                     byte recordType,
                                     long id,
                                     byte[] record)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

appendDeleteRecordTransactional

void appendDeleteRecordTransactional(long txID,
                                     long id)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

appendCommitRecord

void appendCommitRecord(long txID)
                        throws java.lang.Exception

Throws:

java.lang.Exception

appendPrepareRecord

void appendPrepareRecord(long txID)
                         throws java.lang.Exception

Throws:

java.lang.Exception

appendRollbackRecord

void appendRollbackRecord(long txID)
                          throws java.lang.Exception

Throws:

java.lang.Exception

load

long load(java.util.List<RecordInfo> committedRecords,
          java.util.List<PreparedTransactionInfo> preparedTransactions)
          throws java.lang.Exception

Throws:

java.lang.Exception

startReclaimer

void startReclaimer()

stopReclaimer

void stopReclaimer()

getAlignment

int getAlignment()
                 throws java.lang.Exception

Throws:

java.lang.Exception