public final class ReplicationEndpoint extends Object implements ChannelHandler, HornetQComponent
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationEndpoint.JournalSyncFile |
Constructor and Description |
---|
ReplicationEndpoint(HornetQServerImpl server,
IOCriticalErrorListener criticalErrorListener,
boolean wantedFailBack) |
Modifier and Type | Method and Description |
---|---|
void |
compareJournalInformation(JournalLoadInformation[] journalInformation) |
Channel |
getChannel() |
void |
handlePacket(Packet packet) |
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() |
public ReplicationEndpoint(HornetQServerImpl server, IOCriticalErrorListener criticalErrorListener, boolean wantedFailBack)
public void registerJournal(byte id, Journal journal)
public void handlePacket(Packet packet)
handlePacket
in interface ChannelHandler
public boolean isStarted()
isStarted
in interface HornetQComponent
public void start() throws Exception
start
in interface HornetQComponent
Exception
public void stop() throws Exception
stop
in interface HornetQComponent
Exception
public Channel getChannel()
public void setChannel(Channel channel)
public void compareJournalInformation(JournalLoadInformation[] journalInformation) throws HornetQException
HornetQException
public void setDeletePages(boolean deletePages)
public void setQuorumManager(QuorumManager quorumManager)
quorumManager
- public void setExecutor(Executor executor2)
executor2
- Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.