public abstract class XTSATRecoveryManager extends Object
Modifier and Type | Field and Description |
---|---|
protected static XTSATRecoveryManager |
theRecoveryManager
the singleton instance of the recovery manager
|
Constructor and Description |
---|
XTSATRecoveryManager() |
Modifier and Type | Method and Description |
---|---|
abstract void |
addParticipantRecoveryRecord(com.arjuna.ats.arjuna.common.Uid uid,
ATParticipantRecoveryRecord participantRecoveryRecord)
add a recovered participant record to the table of unrecovered participants which
need to be recreated following recovery
|
abstract boolean |
deleteParticipantRecoveryRecord(String id)
remove any participant recovery record with the supplied id from persistent storage
|
abstract ATParticipantRecoveryRecord |
findParticipantRecoveryRecord(String id)
see if a participant recovery record with a given id exists in the table of unrecovered
participants
|
static XTSATRecoveryManager |
getRecoveryManager()
obtain a reference to the WS-AT recovery manager singleton instance
|
abstract boolean |
isCoordinatorRecoveryStarted()
test whether the first AT coordinator recovery scan has completed.
|
abstract boolean |
isParticipantPresent(com.arjuna.ats.arjuna.common.Uid uid)
test whether the supplied uid identifies an active participant or a recovered but inactive
participant
|
abstract boolean |
isParticipantRecoveryStarted()
test whether the first AT participant recovery scan has completed.
|
abstract boolean |
isSubordinateCoordinatorRecoveryStarted()
test whether the first AT subordinate coordinator recovery scan has completed.
|
abstract void |
recoverParticipants()
process all entries in the recovered participant map and attempt to recreate the
application participant and activate it
|
abstract void |
registerRecoveryModule(XTSATRecoveryModule module)
register an application specific recovery module which acts as a helper to recreate
a WS-AT durable participant from the participant's recovery data saved at prepare
|
abstract void |
setCoordinatorRecoveryStarted()
record the fact that the first AT coordinator recovery scan has completed.
|
static XTSATRecoveryManager |
setRecoveryManager(XTSATRecoveryManager recoveryManager)
set the WS-AT recovery manager singleton instance
|
abstract void |
setSubordinateCoordinatorRecoveryStarted()
record the fact that the first AT subordinate coordinator recovery scan has completed.
|
abstract void |
unregisterRecoveryModule(XTSATRecoveryModule module)
unregister an application specific recovery module previously registered as
a helper to recretae WS-AT durable participants
|
abstract boolean |
writeParticipantRecoveryRecord(ATParticipantRecoveryRecord participantRecoveryRecord)
save the supplied participant recovery record to persistent storage
|
protected static XTSATRecoveryManager theRecoveryManager
public static XTSATRecoveryManager getRecoveryManager()
public static XTSATRecoveryManager setRecoveryManager(XTSATRecoveryManager recoveryManager)
recoveryManager
- the instance to use as the recovery managerpublic abstract void registerRecoveryModule(XTSATRecoveryModule module)
module
- the module which will be used to identify and recreate participants
for the applicationNullPointerException
- if the supplied module is nullpublic abstract void unregisterRecoveryModule(XTSATRecoveryModule module) throws NoSuchElementException
module
- the module to be unregisteredNoSuchElementException
- if the module is not currently registeredpublic abstract boolean writeParticipantRecoveryRecord(ATParticipantRecoveryRecord participantRecoveryRecord)
participantRecoveryRecord
- public abstract boolean deleteParticipantRecoveryRecord(String id)
id
- public abstract boolean isParticipantPresent(com.arjuna.ats.arjuna.common.Uid uid)
uid
- public abstract void addParticipantRecoveryRecord(com.arjuna.ats.arjuna.common.Uid uid, ATParticipantRecoveryRecord participantRecoveryRecord)
uid
- the uid under which the participant was saved in the file storeparticipantRecoveryRecord
- the in-memory represenattion of the recovery record
saved to diskpublic abstract ATParticipantRecoveryRecord findParticipantRecoveryRecord(String id)
id
- the identifier of the participant being soughtpublic abstract void recoverParticipants()
public abstract boolean isParticipantRecoveryStarted()
public abstract boolean isCoordinatorRecoveryStarted()
public abstract boolean isSubordinateCoordinatorRecoveryStarted()
public abstract void setCoordinatorRecoveryStarted()
public abstract void setSubordinateCoordinatorRecoveryStarted()
Copyright © 2017 JBoss by Red Hat. All rights reserved.