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

Class SharedNothingPrimaryActivation

java.lang.Object

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

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

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

All Implemented Interfaces:

Runnable

public class SharedNothingPrimaryActivation
extends PrimaryActivation

Constructor Summary

Constructors

Constructor	Description
SharedNothingPrimaryActivation(ActiveMQServerImpl activeMQServer, ReplicatedPolicy replicatedPolicy)

Method Summary

Modifier and Type	Method	Description
void	close(boolean permanently, boolean restarting)
void	freezeConnections(RemotingService remotingService)	freeze the connection but allow the Activation to over ride this and decide if any connections should be left open.
void	freezeReplication()
ChannelHandler	getActivationChannelHandler(Channel channel, Acceptor acceptorUsed)	allows the Activation to register a channel handler so it can handle any packets that are unique to the Activation
ReplicationManager	getReplicationManager()
boolean	isReplicaSync()
void	run()
void	sendPrimaryIsStopping()	called by the server to notify the Activation that the server is stopping
void	startReplication(CoreRemotingConnection rc, ClusterConnection clusterConnection, Pair<TransportConfiguration,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 Details

SharedNothingPrimaryActivation

public SharedNothingPrimaryActivation(ActiveMQServerImpl activeMQServer,
 ReplicatedPolicy replicatedPolicy)

Method Details

freezeConnections

public void freezeConnections(RemotingService remotingService)

Description copied from class: Activation

freeze the connection but allow the Activation to over ride this and decide if any connections should be left open.

Overrides:

freezeConnections in class Activation

freezeReplication

public void freezeReplication()

run

public void run()

getActivationChannelHandler

public ChannelHandler getActivationChannelHandler(Channel channel,
 Acceptor acceptorUsed)

Description copied from class: Activation

allows the Activation to register a channel handler so it can handle any packets that are unique to the Activation

Overrides:

getActivationChannelHandler in class Activation

startReplication

public void startReplication(CoreRemotingConnection rc,
 ClusterConnection clusterConnection,
 Pair<TransportConfiguration,TransportConfiguration> pair,
 boolean isFailBackRequest)
                      throws ActiveMQException

Throws:

ActiveMQException

close

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

Specified by:

close in class Activation

Throws:

Exception

sendPrimaryIsStopping

public void sendPrimaryIsStopping()

Description copied from class: Activation

called by the server to notify the Activation that the server is stopping

Overrides:

sendPrimaryIsStopping in class Activation

getReplicationManager

public ReplicationManager getReplicationManager()

Overrides:

getReplicationManager in class Activation

isReplicaSync

public boolean isReplicaSync()

Overrides:

isReplicaSync in class Activation