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

Class ColocatedActivation

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.ColocatedActivation

All Implemented Interfaces:

Runnable

public class ColocatedActivation
extends PrimaryActivation

Constructor Summary

Constructors

Constructor	Description
ColocatedActivation(ActiveMQServerImpl activeMQServer, ColocatedPolicy colocatedPolicy, PrimaryActivation primaryActivation)

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.
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
HAManager	getHAManager()	Returns the HA manager used for this Activation.
ReplicationManager	getReplicationManager()
void	haStarted()	called by the ha manager to notify the Activation that HA is now active
void	postConnectionFreeze()	allow the activation to override this if it needs to tidy up after freezing the connection. it's a different method as it's called outside of the lock that the previous method is.
void	preStorageClose()	called before the server is closing the journals so the activation can tidy up stuff
void	run()
void	sendPrimaryIsStopping()	called by the server to notify the Activation that the server is stopping

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

createJournalLoader, isReplicaSync

Methods inherited from class java.lang.Object

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

Constructor Details

ColocatedActivation

public ColocatedActivation(ActiveMQServerImpl activeMQServer,
 ColocatedPolicy colocatedPolicy,
 PrimaryActivation primaryActivation)

Method Details

haStarted

public void haStarted()

Description copied from class: Activation

called by the ha manager to notify the Activation that HA is now active

Overrides:

haStarted in class Activation

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

postConnectionFreeze

public void postConnectionFreeze()

Description copied from class: Activation

allow the activation to override this if it needs to tidy up after freezing the connection. it's a different method as it's called outside of the lock that the previous method is.

Overrides:

postConnectionFreeze in class Activation

preStorageClose

public void preStorageClose()
                     throws Exception

Description copied from class: Activation

called before the server is closing the journals so the activation can tidy up stuff

Overrides:

preStorageClose 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

getHAManager

public HAManager getHAManager()

Description copied from class: Activation

Returns the HA manager used for this Activation.

Overrides:

getHAManager in class Activation

Returns:

the HA manager used for this Activation

run

public void run()

close

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

Specified by:

close in class Activation

Throws:

Exception

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