org.hornetq.core.replication.impl

Class ReplicatedJournal

java.lang.Object

org.hornetq.core.replication.impl.ReplicatedJournal

All Implemented Interfaces:

Journal, HornetQComponent

public class ReplicatedJournal
extends Object
implements Journal

Used by the JournalStorageManager to replicate journal calls.

Author:

Clebert Suconic

See Also:

JournalStorageManager

Constructor Summary

Constructors

Constructor and Description
ReplicatedJournal(byte journaID, Journal localJournal, ReplicationManager replicationManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	appendAddRecord(long id, byte recordType, byte[] record, boolean sync)
void	appendAddRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion completionCallback)
void	appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync)
void	appendAddRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion completionCallback)
void	appendAddRecordTransactional(long txID, long id, byte recordType, byte[] record)
void	appendAddRecordTransactional(long txID, long id, byte recordType, EncodingSupport record)
void	appendCommitRecord(long txID, boolean sync)
void	appendCommitRecord(long txID, boolean sync, IOCompletion callback)
void	appendCommitRecord(long txID, boolean sync, IOCompletion callback, boolean lineUpContext)
void	appendDeleteRecord(long id, boolean sync)
void	appendDeleteRecord(long id, boolean sync, IOCompletion completionCallback)
void	appendDeleteRecordTransactional(long txID, long id)
void	appendDeleteRecordTransactional(long txID, long id, byte[] record)
void	appendDeleteRecordTransactional(long txID, long id, EncodingSupport record)
void	appendPrepareRecord(long txID, byte[] transactionData, boolean sync)
void	appendPrepareRecord(long txID, byte[] transactionData, boolean sync, IOCompletion callback)
void	appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync) If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.
void	appendPrepareRecord(long txID, EncodingSupport transactionData, boolean sync, IOCompletion callback)
void	appendRollbackRecord(long txID, boolean sync)
void	appendRollbackRecord(long txID, boolean sync, IOCompletion callback)
void	appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync)
void	appendUpdateRecord(long id, byte recordType, byte[] record, boolean sync, IOCompletion completionCallback)
void	appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync)
void	appendUpdateRecord(long id, byte recordType, EncodingSupport record, boolean sync, IOCompletion completionCallback)
void	appendUpdateRecordTransactional(long txID, long id, byte recordType, byte[] record)
void	appendUpdateRecordTransactional(long txID, long id, byte recordType, EncodingSupport record)
int	getAlignment()
int	getNumberOfRecords()
int	getUserVersion()
boolean	isStarted()
void	lineUpContex(IOCompletion callback)
JournalLoadInformation	load(List<RecordInfo> committedRecords, List<PreparedTransactionInfo> preparedTransactions, TransactionFailureCallback transactionFailure)
JournalLoadInformation	load(LoaderCallback reloadManager)
JournalLoadInformation	loadInternalOnly() Load internal data structures and not expose any data.
void	perfBlast(int pages)
void	runDirectJournalBlast()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatedJournal

public ReplicatedJournal(byte journaID,
                 Journal localJournal,
                 ReplicationManager replicationManager)

Method Detail

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   byte[] record,
                   boolean sync)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Parameters:

id -

recordType -

record -

sync -

Throws:

Exception

See Also:

Journal.appendAddRecord(long, byte, byte[], boolean)

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   EncodingSupport record,
                   boolean sync)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Throws:

Exception

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   byte[] record,
                   boolean sync,
                   IOCompletion completionCallback)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Throws:

Exception

appendAddRecord

public void appendAddRecord(long id,
                   byte recordType,
                   EncodingSupport record,
                   boolean sync,
                   IOCompletion completionCallback)
                     throws Exception

Specified by:

appendAddRecord in interface Journal

Parameters:

id -

recordType -

record -

sync -

Throws:

Exception

See Also:

Journal.appendAddRecord(long, byte, org.hornetq.core.journal.EncodingSupport, boolean)

appendAddRecordTransactional

public void appendAddRecordTransactional(long txID,
                                long id,
                                byte recordType,
                                byte[] record)
                                  throws Exception

Specified by:

appendAddRecordTransactional in interface Journal

Parameters:

txID -

id -

recordType -

record -

Throws:

Exception

See Also:

Journal.appendAddRecordTransactional(long, long, byte, byte[])

appendAddRecordTransactional

public void appendAddRecordTransactional(long txID,
                                long id,
                                byte recordType,
                                EncodingSupport record)
                                  throws Exception

Specified by:

appendAddRecordTransactional in interface Journal

Parameters:

txID -

id -

recordType -

record -

Throws:

Exception

See Also:

Journal.appendAddRecordTransactional(long, long, byte, org.hornetq.core.journal.EncodingSupport)

appendCommitRecord

public void appendCommitRecord(long txID,
                      boolean sync)
                        throws Exception

Specified by:

appendCommitRecord in interface Journal

Parameters:

txID -

sync -

Throws:

Exception

See Also:

Journal.appendCommitRecord(long, boolean)

appendCommitRecord

public void appendCommitRecord(long txID,
                      boolean sync,
                      IOCompletion callback)
                        throws Exception

Specified by:

appendCommitRecord in interface Journal

Throws:

Exception

appendCommitRecord

public void appendCommitRecord(long txID,
                      boolean sync,
                      IOCompletion callback,
                      boolean lineUpContext)
                        throws Exception

Specified by:

appendCommitRecord in interface Journal

Throws:

Exception

appendDeleteRecord

public void appendDeleteRecord(long id,
                      boolean sync)
                        throws Exception

Specified by:

appendDeleteRecord in interface Journal

Parameters:

id -

sync -

Throws:

Exception

See Also:

Journal.appendDeleteRecord(long, boolean)

appendDeleteRecord

public void appendDeleteRecord(long id,
                      boolean sync,
                      IOCompletion completionCallback)
                        throws Exception

Specified by:

appendDeleteRecord in interface Journal

Throws:

Exception

appendDeleteRecordTransactional

public void appendDeleteRecordTransactional(long txID,
                                   long id,
                                   byte[] record)
                                     throws Exception

Specified by:

appendDeleteRecordTransactional in interface Journal

Parameters:

txID -

id -

record -

Throws:

Exception

See Also:

Journal.appendDeleteRecordTransactional(long, long, byte[])

appendDeleteRecordTransactional

public void appendDeleteRecordTransactional(long txID,
                                   long id,
                                   EncodingSupport record)
                                     throws Exception

Specified by:

appendDeleteRecordTransactional in interface Journal

Parameters:

txID -

id -

record -

Throws:

Exception

See Also:

Journal.appendDeleteRecordTransactional(long, long, org.hornetq.core.journal.EncodingSupport)

appendDeleteRecordTransactional

public void appendDeleteRecordTransactional(long txID,
                                   long id)
                                     throws Exception

Specified by:

appendDeleteRecordTransactional in interface Journal

Parameters:

txID -

id -

Throws:

Exception

See Also:

Journal.appendDeleteRecordTransactional(long, long)

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       byte[] transactionData,
                       boolean sync)
                         throws Exception

Specified by:

appendPrepareRecord in interface Journal

Parameters:

txID -

transactionData -

sync -

Throws:

Exception

See Also:

Journal.appendPrepareRecord(long, byte[], boolean)

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       EncodingSupport transactionData,
                       boolean sync)
                         throws Exception

Description copied from interface: Journal

If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.

transactionData allows you to store any other supporting user-data related to the transaction

Specified by:

appendPrepareRecord in interface Journal

Parameters:

txID -

transactionData -

sync -

Throws:

Exception

See Also:

Journal.appendPrepareRecord(long, org.hornetq.core.journal.EncodingSupport, boolean)

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       EncodingSupport transactionData,
                       boolean sync,
                       IOCompletion callback)
                         throws Exception

Specified by:

appendPrepareRecord in interface Journal

Throws:

Exception

appendPrepareRecord

public void appendPrepareRecord(long txID,
                       byte[] transactionData,
                       boolean sync,
                       IOCompletion callback)
                         throws Exception

Specified by:

appendPrepareRecord in interface Journal

Throws:

Exception

appendRollbackRecord

public void appendRollbackRecord(long txID,
                        boolean sync)
                          throws Exception

Specified by:

appendRollbackRecord in interface Journal

Parameters:

txID -

sync -

Throws:

Exception

See Also:

Journal.appendRollbackRecord(long, boolean)

appendRollbackRecord

public void appendRollbackRecord(long txID,
                        boolean sync,
                        IOCompletion callback)
                          throws Exception

Specified by:

appendRollbackRecord in interface Journal

Throws:

Exception

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      byte[] record,
                      boolean sync)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Parameters:

id -

recordType -

record -

sync -

Throws:

Exception

See Also:

Journal.appendUpdateRecord(long, byte, byte[], boolean)

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      EncodingSupport record,
                      boolean sync)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Parameters:

id -

recordType -

record -

sync -

Throws:

Exception

See Also:

Journal.appendUpdateRecord(long, byte, org.hornetq.core.journal.EncodingSupport, boolean)

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      byte[] record,
                      boolean sync,
                      IOCompletion completionCallback)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Throws:

Exception

appendUpdateRecord

public void appendUpdateRecord(long id,
                      byte recordType,
                      EncodingSupport record,
                      boolean sync,
                      IOCompletion completionCallback)
                        throws Exception

Specified by:

appendUpdateRecord in interface Journal

Throws:

Exception

appendUpdateRecordTransactional

public void appendUpdateRecordTransactional(long txID,
                                   long id,
                                   byte recordType,
                                   byte[] record)
                                     throws Exception

Specified by:

appendUpdateRecordTransactional in interface Journal

Parameters:

txID -

id -

recordType -

record -

Throws:

Exception

See Also:

Journal.appendUpdateRecordTransactional(long, long, byte, byte[])

appendUpdateRecordTransactional

public void appendUpdateRecordTransactional(long txID,
                                   long id,
                                   byte recordType,
                                   EncodingSupport record)
                                     throws Exception

Specified by:

appendUpdateRecordTransactional in interface Journal

Parameters:

txID -

id -

recordType -

record -

Throws:

Exception

See Also:

Journal.appendUpdateRecordTransactional(long, long, byte, org.hornetq.core.journal.EncodingSupport)

load

public JournalLoadInformation load(List<RecordInfo> committedRecords,
                          List<PreparedTransactionInfo> preparedTransactions,
                          TransactionFailureCallback transactionFailure)
                            throws Exception

Specified by:

load in interface Journal

Parameters:

committedRecords -

preparedTransactions -

transactionFailure -

Throws:

Exception

See Also:

Journal.load(java.util.List, java.util.List, org.hornetq.core.journal.TransactionFailureCallback)

load

public JournalLoadInformation load(LoaderCallback reloadManager)
                            throws Exception

Specified by:

load in interface Journal

Parameters:

reloadManager -

Throws:

Exception

See Also:

Journal.load(org.hornetq.core.journal.LoaderCallback)

perfBlast

public void perfBlast(int pages)
               throws Exception

Specified by:

perfBlast in interface Journal

Parameters:

pages -

Throws:

Exception

See Also:

Journal.perfBlast(int)

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

See Also:

HornetQComponent.start()

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

See Also:

HornetQComponent.stop()

getAlignment

public int getAlignment()
                 throws Exception

Specified by:

getAlignment in interface Journal

Throws:

Exception

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

loadInternalOnly

public JournalLoadInformation loadInternalOnly()
                                        throws Exception

Description copied from interface: Journal

Load internal data structures and not expose any data. This is only useful if you're using the journal but not interested on the current data. Useful in situations where the journal is being replicated, copied... etc.

Specified by:

loadInternalOnly in interface Journal

Throws:

Exception

getNumberOfRecords

public int getNumberOfRecords()

Specified by:

getNumberOfRecords in interface Journal

runDirectJournalBlast

public void runDirectJournalBlast()
                           throws Exception

Specified by:

runDirectJournalBlast in interface Journal

Throws:

Exception

getUserVersion

public int getUserVersion()

Specified by:

getUserVersion in interface Journal

lineUpContex

public void lineUpContex(IOCompletion callback)

Specified by:

lineUpContex in interface Journal