public class NoOpXSiteStateTransferManager extends Object implements XSiteStateTransferManager
XSiteStateTransferManager
.
This instance is used when cross-site replication is disabled.STATUS_CANCELED, STATUS_ERROR, STATUS_OK, STATUS_SENDING
Constructor and Description |
---|
NoOpXSiteStateTransferManager() |
Modifier and Type | Method and Description |
---|---|
void |
becomeCoordinator(String siteName)
Makes this node the coordinator for the state transfer to the site name.
|
void |
cancelPushState(String siteName)
It cancels a running state transfer.
|
void |
cancelReceive(String siteName)
Sets the cluster to normal state.
|
void |
clearClusterStatus()
Clears the completed state transfer status in all the cluster.
|
void |
clearStatus()
Clears the completed state transfer status.
|
Map<String,String> |
getClusterStatus() |
List<String> |
getRunningStateTransfers() |
String |
getSendingSiteName() |
XSiteStateConsumer |
getStateConsumer() |
XSiteStateProvider |
getStateProvider() |
Map<String,String> |
getStatus() |
void |
notifyStatePushFinished(String siteName,
Address node,
boolean statusOk)
It receives the notifications from local site when some node finishes pushing the state to the remote site.
|
void |
startPushState(String siteName)
It notifies all nodes from local site to start transfer the state to the remote site.
|
String |
toString() |
public void notifyStatePushFinished(String siteName, Address node, boolean statusOk)
XSiteStateTransferManager
notifyStatePushFinished
in interface XSiteStateTransferManager
siteName
- the remote site namenode
- the Address
from the node that finishes.statusOk
- true
if no error or exception occurred during the state transfer.public void startPushState(String siteName)
XSiteStateTransferManager
startPushState
in interface XSiteStateTransferManager
siteName
- the remote site namepublic void cancelPushState(String siteName)
XSiteStateTransferManager
cancelPushState
in interface XSiteStateTransferManager
siteName
- the site name to where the state is being sent.public List<String> getRunningStateTransfers()
getRunningStateTransfers
in interface XSiteStateTransferManager
public Map<String,String> getStatus()
getStatus
in interface XSiteStateTransferManager
public void clearStatus()
XSiteStateTransferManager
clearStatus
in interface XSiteStateTransferManager
public Map<String,String> getClusterStatus()
getClusterStatus
in interface XSiteStateTransferManager
public void clearClusterStatus()
XSiteStateTransferManager
clearClusterStatus
in interface XSiteStateTransferManager
public String getSendingSiteName()
getSendingSiteName
in interface XSiteStateTransferManager
null
if this node is not receiving state or the site name which is sending the state.public void cancelReceive(String siteName)
XSiteStateTransferManager
cancelReceive
in interface XSiteStateTransferManager
siteName
- the site name which is sending the state.public void becomeCoordinator(String siteName)
XSiteStateTransferManager
becomeCoordinator
in interface XSiteStateTransferManager
siteName
- the site name.public XSiteStateProvider getStateProvider()
getStateProvider
in interface XSiteStateTransferManager
public XSiteStateConsumer getStateConsumer()
getStateConsumer
in interface XSiteStateTransferManager
Copyright © 2021 JBoss by Red Hat. All rights reserved.