public class ScaleDownHandler extends Object
Modifier and Type | Class and Description |
---|---|
static class |
ScaleDownHandler.OrderQueueByNumberOfReferencesComparator |
Constructor and Description |
---|
ScaleDownHandler(PagingManager pagingManager,
PostOffice postOffice,
NodeManager nodeManager,
ClusterController clusterController,
StorageManager storageManager) |
Modifier and Type | Method and 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) |
public ScaleDownHandler(PagingManager pagingManager, PostOffice postOffice, NodeManager nodeManager, ClusterController clusterController, StorageManager storageManager)
public long scaleDown(ClientSessionFactory sessionFactory, ResourceManager resourceManager, Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, SimpleString managementAddress, SimpleString targetNodeId) throws Exception
Exception
public long scaleDownMessages(ClientSessionFactory sessionFactory, SimpleString nodeId, String user, String password) throws Exception
Exception
public long scaleDownRegularMessages(SimpleString address, Set<Queue> queues, ClientSession clientSession, ClientProducer producer) throws Exception
Exception
public void scaleDownTransactions(ClientSessionFactory sessionFactory, ResourceManager resourceManager, String user, String password) throws Exception
Exception
public void scaleDownDuplicateIDs(Map<SimpleString,List<Pair<byte[],Long>>> duplicateIDMap, ClientSessionFactory sessionFactory, SimpleString managementAddress, String user, String password) throws Exception
Exception
Copyright © 2020 JBoss by Red Hat. All rights reserved.