public final class ReplicationEndpoint extends Object implements ChannelHandler, ActiveMQComponent
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationEndpoint.JournalSyncFile |
Constructor and Description |
---|
ReplicationEndpoint(ActiveMQServerImpl server,
IOCriticalErrorListener criticalErrorListener,
boolean wantedFailBack,
SharedNothingBackupActivation activation) |
Modifier and Type | Method and Description |
---|---|
void |
addOutgoingInterceptorForReplication(Interceptor interceptor) |
Channel |
getChannel() |
void |
handlePacket(Packet packet)
called by the channel when a packet is received..
|
boolean |
isStarted() |
void |
pause()
This is for tests basically, do not use it as its API is not guaranteed for future usage.
|
void |
registerJournal(byte id,
Journal journal) |
void |
resume()
This is for tests basically, do not use it as its API is not guaranteed for future usage.
|
protected void |
sendResponse(PacketImpl response) |
void |
setBackupQuorum(SharedNothingBackupQuorum backupQuorum)
Sets the quorumManager used by the server in the replicationEndpoint.
|
void |
setChannel(Channel channel) |
void |
setExecutor(Executor executor2) |
void |
start() |
void |
stop() |
public ReplicationEndpoint(ActiveMQServerImpl server, IOCriticalErrorListener criticalErrorListener, boolean wantedFailBack, SharedNothingBackupActivation activation)
public void registerJournal(byte id, Journal journal)
public void addOutgoingInterceptorForReplication(Interceptor interceptor)
public void pause()
public void resume()
public void handlePacket(Packet packet)
ChannelHandler
handlePacket
in interface ChannelHandler
packet
- the packet receivedprotected void sendResponse(PacketImpl response)
public boolean isStarted()
isStarted
in interface ActiveMQComponent
public void start() throws Exception
start
in interface ActiveMQComponent
Exception
public void stop() throws Exception
stop
in interface ActiveMQComponent
Exception
public Channel getChannel()
public void setChannel(Channel channel)
public void setBackupQuorum(SharedNothingBackupQuorum backupQuorum)
backupQuorum
- public void setExecutor(Executor executor2)
executor2
- Copyright © 2020 JBoss by Red Hat. All rights reserved.