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

Class SharedStorePrimaryActivation

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

All Implemented Interfaces:

Runnable

public final class SharedStorePrimaryActivation
extends PrimaryActivation

Constructor Summary

Constructors

Constructor	Description
SharedStorePrimaryActivation(ActiveMQServerImpl server, SharedStorePrimaryPolicy sharedStorePrimaryPolicy, IOCriticalErrorListener ioCriticalErrorListener)

Method Summary

Modifier and Type	Method	Description
void	close(boolean permanently, boolean restarting)
void	run()

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

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

Methods inherited from class java.lang.Object

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

Constructor Details

SharedStorePrimaryActivation

public SharedStorePrimaryActivation(ActiveMQServerImpl server,
 SharedStorePrimaryPolicy sharedStorePrimaryPolicy,
 IOCriticalErrorListener ioCriticalErrorListener)

Method Details

run

public void run()

close

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

Specified by:

close in class Activation

Throws:

Exception