com.atomikos.remoting.recovery

Class RemotingRecoverableResource

java.lang.Object

com.atomikos.remoting.recovery.RemotingRecoverableResource

All Implemented Interfaces:

com.atomikos.datasource.RecoverableResource

public class RemotingRecoverableResource
extends Object
implements com.atomikos.datasource.RecoverableResource

Constructor Summary

Constructors

Constructor and Description
RemotingRecoverableResource(String uniqueResourceName, RemotingRecoveryLog remotingRecoveryLog)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RemotingRecoverableResource

public RemotingRecoverableResource(String uniqueResourceName,
                                   RemotingRecoveryLog remotingRecoveryLog)

Method Detail

setRecoveryService

public void setRecoveryService(com.atomikos.icatch.RecoveryService recoveryService)
                        throws com.atomikos.datasource.ResourceException

Specified by:

setRecoveryService in interface com.atomikos.datasource.RecoverableResource

Throws:

com.atomikos.datasource.ResourceException

close

public void close()
           throws com.atomikos.datasource.ResourceException

Specified by:

close in interface com.atomikos.datasource.RecoverableResource

Throws:

com.atomikos.datasource.ResourceException

getName

public String getName()

Specified by:

getName in interface com.atomikos.datasource.RecoverableResource

isSameRM

public boolean isSameRM(com.atomikos.datasource.RecoverableResource res)
                 throws com.atomikos.datasource.ResourceException

Specified by:

isSameRM in interface com.atomikos.datasource.RecoverableResource

Throws:

com.atomikos.datasource.ResourceException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface com.atomikos.datasource.RecoverableResource

recover

public boolean recover(long startOfRecoveryScan,
                       Collection<com.atomikos.recovery.PendingTransactionRecord> expiredCommittingCoordinators,
                       Collection<com.atomikos.recovery.PendingTransactionRecord> indoubtForeignCoordinatorsToKeep)

Specified by:

recover in interface com.atomikos.datasource.RecoverableResource

hasPendingParticipantsFromLastRecoveryScan

public boolean hasPendingParticipantsFromLastRecoveryScan()

Specified by:

hasPendingParticipantsFromLastRecoveryScan in interface com.atomikos.datasource.RecoverableResource