org.hornetq.core.replication

Class ReplicationEndpoint

java.lang.Object

org.hornetq.core.replication.ReplicationEndpoint

All Implemented Interfaces:

ChannelHandler, HornetQComponent

public final class ReplicationEndpoint
extends Object
implements ChannelHandler, HornetQComponent

Handles all the synchronization necessary for replication on the backup side (that is the backup's side of the "remote backup" use case).

Author:

Clebert Suconic

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReplicationEndpoint.JournalSyncFile

Constructor Summary

Constructors

Constructor and Description
ReplicationEndpoint(HornetQServerImpl server, IOCriticalErrorListener criticalErrorListener, boolean wantedFailBack)

Method Summary

Modifier and Type	Method and Description
void	compareJournalInformation(JournalLoadInformation[] journalInformation)
Channel	getChannel()
void	handlePacket(Packet packet) called by the channel when a packet is received..
boolean	isStarted()
void	registerJournal(byte id, Journal journal)
void	setChannel(Channel channel)
void	setDeletePages(boolean deletePages) Used on tests only.
void	setExecutor(Executor executor2)
void	setQuorumManager(QuorumManager quorumManager) Sets the quorumManager used by the server in the replicationEndpoint.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationEndpoint

public ReplicationEndpoint(HornetQServerImpl server,
                           IOCriticalErrorListener criticalErrorListener,
                           boolean wantedFailBack)

Method Detail

registerJournal

public void registerJournal(byte id,
                            Journal journal)

handlePacket

public void handlePacket(Packet packet)

Description copied from interface: ChannelHandler

called by the channel when a packet is received..

Specified by:

handlePacket in interface ChannelHandler

Parameters:

packet - the packet received

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

getChannel

public Channel getChannel()

setChannel

public void setChannel(Channel channel)

compareJournalInformation

public void compareJournalInformation(JournalLoadInformation[] journalInformation)
                               throws HornetQException

Throws:

HornetQException

setDeletePages

public void setDeletePages(boolean deletePages)

Used on tests only. To simulate missing page deletes

setQuorumManager

public void setQuorumManager(QuorumManager quorumManager)

Sets the quorumManager used by the server in the replicationEndpoint. It is used to inform the backup server of the live's nodeID.

Parameters:

quorumManager -

setExecutor

public void setExecutor(Executor executor2)

Parameters:

executor2 -