org.hornetq.core.replication.impl

Class ReplicationManagerImpl

java.lang.Object

org.hornetq.core.replication.impl.ReplicationManagerImpl

All Implemented Interfaces:

ReplicationManager, HornetQComponent

public class ReplicationManagerImpl
extends Object
implements ReplicationManager

A RepplicationManagerImpl

Author:

Clebert Suconic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ReplicationManagerImpl.ResponseHandler

Constructor Summary

Constructors

Constructor and Description
ReplicationManagerImpl(ClientSessionFactoryInternal sessionFactory, ExecutorFactory executorFactory)

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
boolean	isStarted()
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)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationManagerImpl

public ReplicationManagerImpl(ClientSessionFactoryInternal sessionFactory,
                      ExecutorFactory executorFactory)

Method Detail

appendAddRecord

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

Specified by:

appendAddRecord in interface ReplicationManager

appendUpdateRecord

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

Specified by:

appendUpdateRecord in interface ReplicationManager

Throws:

Exception

appendDeleteRecord

public void appendDeleteRecord(byte journalID,
                      long id)
                        throws Exception

Specified by:

appendDeleteRecord in interface ReplicationManager

Throws:

Exception

appendAddRecordTransactional

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

Specified by:

appendAddRecordTransactional in interface ReplicationManager

Throws:

Exception

appendUpdateRecordTransactional

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

Specified by:

appendUpdateRecordTransactional in interface ReplicationManager

Throws:

Exception

appendCommitRecord

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

Specified by:

appendCommitRecord in interface ReplicationManager

Throws:

Exception

appendDeleteRecordTransactional

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

Specified by:

appendDeleteRecordTransactional in interface ReplicationManager

Throws:

Exception

appendDeleteRecordTransactional

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

Specified by:

appendDeleteRecordTransactional in interface ReplicationManager

Throws:

Exception

appendPrepareRecord

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

Specified by:

appendPrepareRecord in interface ReplicationManager

Throws:

Exception

appendRollbackRecord

public void appendRollbackRecord(byte journalID,
                        long txID)
                          throws Exception

Specified by:

appendRollbackRecord in interface ReplicationManager

Throws:

Exception

pageClosed

public void pageClosed(SimpleString storeName,
              int pageNumber)

Specified by:

pageClosed in interface ReplicationManager

pageDeleted

public void pageDeleted(SimpleString storeName,
               int pageNumber)

Specified by:

pageDeleted in interface ReplicationManager

pageWrite

public void pageWrite(PagedMessage message,
             int pageNumber)

Specified by:

pageWrite in interface ReplicationManager

largeMessageBegin

public void largeMessageBegin(long messageId)

Specified by:

largeMessageBegin in interface ReplicationManager

largeMessageDelete

public void largeMessageDelete(long messageId)

Specified by:

largeMessageDelete in interface ReplicationManager

largeMessageWrite

public void largeMessageWrite(long messageId,
                     byte[] body)

Specified by:

largeMessageWrite in interface ReplicationManager

isStarted

public boolean isStarted()

Specified by:

isStarted in interface HornetQComponent

start

public void start()
           throws Exception

Specified by:

start in interface HornetQComponent

Throws:

Exception

stop

public void stop()
          throws Exception

Specified by:

stop in interface HornetQComponent

Throws:

Exception

getActiveTokens

public Set<OperationContext> getActiveTokens()

Description copied from interface: ReplicationManager

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

Specified by:

getActiveTokens in interface ReplicationManager

compareJournals

public void compareJournals(JournalLoadInformation[] journalInfo)
                     throws HornetQException

Specified by:

compareJournals in interface ReplicationManager

Throws:

HornetQException