public class XSiteStateProviderImpl extends Object implements XSiteStateProvider
Constructor and Description |
---|
XSiteStateProviderImpl() |
Modifier and Type | Method and Description |
---|---|
void |
cancelStateTransfer(String siteName)
It cancels the state transfer for the remote site.
|
Collection<String> |
getCurrentStateSending() |
Collection<String> |
getSitesMissingCoordinator(Collection<Address> currentMembers) |
void |
inject(DataContainer dataContainer,
PersistenceManager persistenceManager,
RpcManager rpcManager,
ClusteringDependentLogic clusteringDependentLogic,
CommandsFactory commandsFactory,
ExecutorService executorService,
Configuration configuration,
XSiteStateTransferManager xSiteStateTransferManager,
StateTransferLock stateTransferLock) |
void |
startStateTransfer(String siteName,
Address origin,
int minTopologyId)
It notifies this node to start sending state to the remote site.
|
public void inject(DataContainer dataContainer, PersistenceManager persistenceManager, RpcManager rpcManager, ClusteringDependentLogic clusteringDependentLogic, CommandsFactory commandsFactory, ExecutorService executorService, Configuration configuration, XSiteStateTransferManager xSiteStateTransferManager, StateTransferLock stateTransferLock)
public void startStateTransfer(String siteName, Address origin, int minTopologyId)
XSiteStateProvider
startStateTransfer
in interface XSiteStateProvider
siteName
- the remote site name.origin
- the requestor.public void cancelStateTransfer(String siteName)
XSiteStateProvider
cancelStateTransfer
in interface XSiteStateProvider
siteName
- the remote site name.public Collection<String> getCurrentStateSending()
getCurrentStateSending
in interface XSiteStateProvider
public Collection<String> getSitesMissingCoordinator(Collection<Address> currentMembers)
getSitesMissingCoordinator
in interface XSiteStateProvider
currentMembers
.Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.