org.hornetq.core.replication.impl

Class ReplicationEndpointImpl

java.lang.Object

org.hornetq.core.replication.impl.ReplicationEndpointImpl

All Implemented Interfaces:

ChannelHandler, ReplicationEndpoint, HornetQComponent

public class ReplicationEndpointImpl
extends Object
implements ReplicationEndpoint

Author:

Clebert Suconic

Constructor Summary

Constructors

Constructor and Description
ReplicationEndpointImpl(HornetQServer server, IOCriticalErrorListener criticalErrorListener)

Method Summary

Methods

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationEndpointImpl

public ReplicationEndpointImpl(HornetQServer server,
                       IOCriticalErrorListener criticalErrorListener)

Method Detail

registerJournal

public void registerJournal(byte id,
                   Journal journal)

Specified by:

registerJournal in interface ReplicationEndpoint

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()

Specified by:

getChannel in interface ReplicationEndpoint

setChannel

public void setChannel(Channel channel)

Specified by:

setChannel in interface ReplicationEndpoint

compareJournalInformation

public void compareJournalInformation(JournalLoadInformation[] journalInformation)
                               throws HornetQException

Specified by:

compareJournalInformation in interface ReplicationEndpoint

Throws:

HornetQException

setDeletePages

public void setDeletePages(boolean deletePages)

Used on tests only. To simulate missing page deletes