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

Class PrimaryOnlyActivation

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public class PrimaryOnlyActivation
extends Activation

Constructor Summary

Constructors

Constructor	Description
PrimaryOnlyActivation(ActiveMQServerImpl server, PrimaryOnlyPolicy primaryOnlyPolicy)

Method Summary

Modifier and Type	Method	Description
void	close(boolean permanently, boolean restarting)
void	connectToScaleDownTarget(ScaleDownPolicy scaleDownPolicy)
void	freezeConnections(RemotingService remotingService)	freeze the connection but allow the Activation to over ride this and decide if any connections should be left open.
PrimaryOnlyPolicy	getPrimaryOnlyPolicy()
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	run()
long	scaleDown(int commitInterval)

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

createJournalLoader, getActivationChannelHandler, getHAManager, getReplicationManager, haStarted, isReplicaSync, preStorageClose, sendPrimaryIsStopping

Methods inherited from class java.lang.Object

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

Constructor Details

PrimaryOnlyActivation

public PrimaryOnlyActivation(ActiveMQServerImpl server,
 PrimaryOnlyPolicy primaryOnlyPolicy)

Method Details

getPrimaryOnlyPolicy

public PrimaryOnlyPolicy getPrimaryOnlyPolicy()

run

public void run()

close

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

Specified by:

close in class Activation

Throws:

Exception

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

connectToScaleDownTarget

public void connectToScaleDownTarget(ScaleDownPolicy scaleDownPolicy)

scaleDown

public long scaleDown(int commitInterval)
               throws Exception

Throws:

Exception