org.hornetq.core.replication

Interface ReplicationManager

All Superinterfaces:

HornetQComponent

All Known Implementing Classes:

ReplicationManagerImpl

public interface ReplicationManager
extends HornetQComponent

Author:

Clebert Suconic

Method Summary

Methods

Modifier and Type	Method and Description
void	appendAddRecord(byte journalID, long id, byte recordType, EncodingSupport record)
void	appendAddRecordTransactional(byte journalID, long txID, long id, byte recordType, EncodingSupport record)
void	appendCommitRecord(byte journalID, long txID, boolean lineUp)
void	appendDeleteRecord(byte journalID, long id)
void	appendDeleteRecordTransactional(byte journalID, long txID, long id)
void	appendDeleteRecordTransactional(byte journalID, long txID, long id, EncodingSupport record)
void	appendPrepareRecord(byte journalID, long txID, EncodingSupport transactionData)
void	appendRollbackRecord(byte journalID, long txID)
void	appendUpdateRecord(byte journalID, long id, byte recordType, EncodingSupport record)
void	appendUpdateRecordTransactional(byte journalID, long txID, long id, byte recordType, EncodingSupport record)
void	compareJournals(JournalLoadInformation[] journalInfo)
Set<OperationContext>	getActiveTokens() A list of tokens that are still waiting for replications to be completed
void	largeMessageBegin(long messageId)
void	largeMessageDelete(long messageId)
void	largeMessageWrite(long messageId, byte[] body)
void	pageClosed(SimpleString storeName, int pageNumber)
void	pageDeleted(SimpleString storeName, int pageNumber)
void	pageWrite(PagedMessage message, int pageNumber)

Methods inherited from interface org.hornetq.core.server.HornetQComponent

isStarted, start, stop

Method Detail

appendAddRecord

void appendAddRecord(byte journalID,
                   long id,
                   byte recordType,
                   EncodingSupport record)
                     throws Exception

Throws:

Exception

appendUpdateRecord

void appendUpdateRecord(byte journalID,
                      long id,
                      byte recordType,
                      EncodingSupport record)
                        throws Exception

Throws:

Exception

appendDeleteRecord

void appendDeleteRecord(byte journalID,
                      long id)
                        throws Exception

Throws:

Exception

appendAddRecordTransactional

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

Throws:

Exception

appendUpdateRecordTransactional

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

Throws:

Exception

appendDeleteRecordTransactional

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

Throws:

Exception

appendDeleteRecordTransactional

void appendDeleteRecordTransactional(byte journalID,
                                   long txID,
                                   long id)
                                     throws Exception

Throws:

Exception

appendCommitRecord

void appendCommitRecord(byte journalID,
                      long txID,
                      boolean lineUp)
                        throws Exception

Throws:

Exception

appendPrepareRecord

void appendPrepareRecord(byte journalID,
                       long txID,
                       EncodingSupport transactionData)
                         throws Exception

Throws:

Exception

appendRollbackRecord

void appendRollbackRecord(byte journalID,
                        long txID)
                          throws Exception

Throws:

Exception

getActiveTokens

Set<OperationContext> getActiveTokens()

A list of tokens that are still waiting for replications to be completed

pageClosed

void pageClosed(SimpleString storeName,
              int pageNumber)

Parameters:

storeName -

pageNumber -

pageDeleted

void pageDeleted(SimpleString storeName,
               int pageNumber)

Parameters:

storeName -

pageNumber -

pageWrite

void pageWrite(PagedMessage message,
             int pageNumber)

Parameters:

message -

pageNumber -

largeMessageBegin

void largeMessageBegin(long messageId)

largeMessageWrite

void largeMessageWrite(long messageId,
                     byte[] body)

largeMessageDelete

void largeMessageDelete(long messageId)

compareJournals

void compareJournals(JournalLoadInformation[] journalInfo)
                     throws HornetQException

Parameters:

journalInfo -

Throws:

HornetQException