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

Class ScaleDownHandler

java.lang.Object

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

public class ScaleDownHandler
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ScaleDownHandler.OrderQueueByNumberOfReferencesComparator

Constructor Summary

Constructors

Constructor	Description
ScaleDownHandler(PagingManager pagingManager, PostOffice postOffice, NodeManager nodeManager, ClusterController clusterController, StorageManager storageManager, int commitInterval)

Method Summary

Modifier and Type	Method	Description
long	scaleDown(ClientSessionFactory sessionFactory, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, SimpleString managementAddress, SimpleString targetNodeId)
void	scaleDownDuplicateIDs(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, ClientSessionFactory sessionFactory, SimpleString managementAddress, String user, String password)
long	scaleDownMessages(ClientSessionFactory sessionFactory, SimpleString nodeId, String user, String password)
long	scaleDownRegularMessages(SimpleString address, Set<Queue> queues, ClientSession clientSession, ClientProducer producer)
void	scaleDownTransactions(ClientSessionFactory sessionFactory, ResourceManager resourceManager, String user, String password)

Methods inherited from class java.lang.Object

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

Constructor Details

ScaleDownHandler

public ScaleDownHandler(PagingManager pagingManager,
 PostOffice postOffice,
 NodeManager nodeManager,
 ClusterController clusterController,
 StorageManager storageManager,
 int commitInterval)

Method Details

scaleDown

public long scaleDown(ClientSessionFactory sessionFactory,
 ResourceManager resourceManager,
 Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
 SimpleString managementAddress,
 SimpleString targetNodeId)
               throws Exception

Throws:

Exception

scaleDownMessages

public long scaleDownMessages(ClientSessionFactory sessionFactory,
 SimpleString nodeId,
 String user,
 String password)
                       throws Exception

Throws:

Exception

scaleDownRegularMessages

public long scaleDownRegularMessages(SimpleString address,
 Set<Queue> queues,
 ClientSession clientSession,
 ClientProducer producer)
                              throws Exception

Throws:

Exception

scaleDownTransactions

public void scaleDownTransactions(ClientSessionFactory sessionFactory,
 ResourceManager resourceManager,
 String user,
 String password)
                           throws Exception

Throws:

Exception

scaleDownDuplicateIDs

public void scaleDownDuplicateIDs(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap,
 ClientSessionFactory sessionFactory,
 SimpleString managementAddress,
 String user,
 String password)
                           throws Exception

Throws:

Exception