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

Class LiveOnlyActivation

java.lang.Object

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

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

All Implemented Interfaces:

Runnable

public class LiveOnlyActivation
extends Activation

Constructor Summary

Constructors

Constructor and Description
LiveOnlyActivation(ActiveMQServerImpl server, LiveOnlyPolicy liveOnlyPolicy)

Method Summary

Modifier and Type	Method and Description
void	close(boolean permanently, boolean restarting)
void	connectToScaleDownTarget(ScaleDownPolicy scaleDownPolicy)
void	freezeConnections(RemotingService remotingService)
void	postConnectionFreeze()
void	run()
long	scaleDown()

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

createJournalLoader, getActivationChannelHandler, getHAManager, getReplicationManager, haStarted, preStorageClose, sendLiveIsStopping

Methods inherited from class java.lang.Object

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

Constructor Detail

LiveOnlyActivation

public LiveOnlyActivation(ActiveMQServerImpl server,
                          LiveOnlyPolicy liveOnlyPolicy)

Method Detail

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)

Overrides:

freezeConnections in class Activation

postConnectionFreeze

public void postConnectionFreeze()

Overrides:

postConnectionFreeze in class Activation

connectToScaleDownTarget

public void connectToScaleDownTarget(ScaleDownPolicy scaleDownPolicy)

scaleDown

public long scaleDown()
               throws Exception

Throws:

Exception