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()
|
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
Copyright © 2006 JBoss Inc. All Rights Reserved.