public class RemotingRecoverableResource extends Object implements com.atomikos.datasource.RecoverableResource
| Constructor and Description |
|---|
RemotingRecoverableResource(String uniqueResourceName,
RemotingRecoveryLog remotingRecoveryLog) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
String |
getName() |
boolean |
hasPendingParticipantsFromLastRecoveryScan() |
boolean |
isClosed() |
boolean |
isSameRM(com.atomikos.datasource.RecoverableResource res) |
boolean |
recover(long startOfRecoveryScan,
Collection<com.atomikos.recovery.PendingTransactionRecord> expiredCommittingCoordinators,
Collection<com.atomikos.recovery.PendingTransactionRecord> indoubtForeignCoordinatorsToKeep) |
void |
setRecoveryService(com.atomikos.icatch.RecoveryService recoveryService) |
public RemotingRecoverableResource(String uniqueResourceName, RemotingRecoveryLog remotingRecoveryLog)
public void setRecoveryService(com.atomikos.icatch.RecoveryService recoveryService)
throws com.atomikos.datasource.ResourceException
setRecoveryService in interface com.atomikos.datasource.RecoverableResourcecom.atomikos.datasource.ResourceExceptionpublic void close()
throws com.atomikos.datasource.ResourceException
close in interface com.atomikos.datasource.RecoverableResourcecom.atomikos.datasource.ResourceExceptionpublic String getName()
getName in interface com.atomikos.datasource.RecoverableResourcepublic boolean isSameRM(com.atomikos.datasource.RecoverableResource res)
throws com.atomikos.datasource.ResourceException
isSameRM in interface com.atomikos.datasource.RecoverableResourcecom.atomikos.datasource.ResourceExceptionpublic boolean isClosed()
isClosed in interface com.atomikos.datasource.RecoverableResourcepublic boolean recover(long startOfRecoveryScan,
Collection<com.atomikos.recovery.PendingTransactionRecord> expiredCommittingCoordinators,
Collection<com.atomikos.recovery.PendingTransactionRecord> indoubtForeignCoordinatorsToKeep)
recover in interface com.atomikos.datasource.RecoverableResourcepublic boolean hasPendingParticipantsFromLastRecoveryScan()
hasPendingParticipantsFromLastRecoveryScan in interface com.atomikos.datasource.RecoverableResourceCopyright © 2026. All rights reserved.