org.apache.activemq.artemis.core.server.impl

Class SharedNothingLiveActivation

java.lang.Object

org.apache.activemq.artemis.core.server.impl.Activation

org.apache.activemq.artemis.core.server.impl.LiveActivation

org.apache.activemq.artemis.core.server.impl.SharedNothingLiveActivation

All Implemented Interfaces:

Runnable

public class SharedNothingLiveActivation
extends LiveActivation

Constructor Summary

Constructors

Constructor and Description
SharedNothingLiveActivation(ActiveMQServerImpl activeMQServer, ReplicatedPolicy replicatedPolicy)

Method Summary

Modifier and Type	Method and Description
void	close(boolean permanently, boolean restarting)
void	freezeConnections(RemotingService remotingService)
org.apache.activemq.artemis.core.protocol.core.ChannelHandler	getActivationChannelHandler(org.apache.activemq.artemis.core.protocol.core.Channel channel, Acceptor acceptorUsed)
ReplicationManager	getReplicationManager()
void	run()
void	sendLiveIsStopping()
void	startReplication(org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection rc, ClusterConnection clusterConnection, org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> pair, boolean isFailBackRequest)

Methods inherited from class org.apache.activemq.artemis.core.server.impl.Activation

createJournalLoader, getHAManager, haStarted, postConnectionFreeze, preStorageClose

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedNothingLiveActivation

public SharedNothingLiveActivation(ActiveMQServerImpl activeMQServer,
                                   ReplicatedPolicy replicatedPolicy)

Method Detail

freezeConnections

public void freezeConnections(RemotingService remotingService)

Overrides:

freezeConnections in class Activation

run

public void run()

getActivationChannelHandler

public org.apache.activemq.artemis.core.protocol.core.ChannelHandler getActivationChannelHandler(org.apache.activemq.artemis.core.protocol.core.Channel channel,
                                                                                                 Acceptor acceptorUsed)

Overrides:

getActivationChannelHandler in class Activation

startReplication

public void startReplication(org.apache.activemq.artemis.core.protocol.core.CoreRemotingConnection rc,
                             ClusterConnection clusterConnection,
                             org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> pair,
                             boolean isFailBackRequest)
                      throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

close

public void close(boolean permanently,
                  boolean restarting)
           throws Exception

Specified by:

close in class Activation

Throws:

Exception

sendLiveIsStopping

public void sendLiveIsStopping()

Overrides:

sendLiveIsStopping in class Activation

getReplicationManager

public ReplicationManager getReplicationManager()

Overrides:

getReplicationManager in class Activation