Class AggregateBackupResponse
- java.lang.Object
-
- org.infinispan.remoting.transport.AggregateBackupResponse
-
- All Implemented Interfaces:
BackupResponse
public class AggregateBackupResponse extends Object implements BackupResponse
- Since:
- 5.2
- Author:
- Mircea Markus
-
-
Constructor Summary
Constructors Constructor Description AggregateBackupResponse(BackupResponse onePcResponse, BackupResponse twoPcResponse)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
Set<String>
getCommunicationErrors()
Returns the list of sites where the backups failed due to a bridge communication error (as opposed to an error caused by Infinispan, e.g.Map<String,Throwable>
getFailedBackups()
long
getSendTimeMillis()
Return the time in millis when this operation was initiated.int
hashCode()
boolean
isEmpty()
void
notifyFinish(LongConsumer timeElapsedConsumer)
Registers a listener that is notified when the cross-site request is finished.String
toString()
void
waitForBackupToFinish()
-
-
-
Constructor Detail
-
AggregateBackupResponse
public AggregateBackupResponse(BackupResponse onePcResponse, BackupResponse twoPcResponse)
-
-
Method Detail
-
waitForBackupToFinish
public void waitForBackupToFinish() throws Exception
- Specified by:
waitForBackupToFinish
in interfaceBackupResponse
- Throws:
Exception
-
getFailedBackups
public Map<String,Throwable> getFailedBackups()
- Specified by:
getFailedBackups
in interfaceBackupResponse
-
getCommunicationErrors
public Set<String> getCommunicationErrors()
Description copied from interface:BackupResponse
Returns the list of sites where the backups failed due to a bridge communication error (as opposed to an error caused by Infinispan, e.g. due to a lock acquisition timeout).- Specified by:
getCommunicationErrors
in interfaceBackupResponse
-
getSendTimeMillis
public long getSendTimeMillis()
Description copied from interface:BackupResponse
Return the time in millis when this operation was initiated.- Specified by:
getSendTimeMillis
in interfaceBackupResponse
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmpty
in interfaceBackupResponse
-
notifyFinish
public void notifyFinish(LongConsumer timeElapsedConsumer)
Description copied from interface:BackupResponse
Registers a listener that is notified when the cross-site request is finished.The parameter is the time spent in the network in milliseconds.
- Specified by:
notifyFinish
in interfaceBackupResponse
- Parameters:
timeElapsedConsumer
- TheConsumer
to be invoke.
-
-