public class XTSATRecoveryManagerImple extends XTSATRecoveryManager
theRecoveryManager
Constructor and Description |
---|
XTSATRecoveryManagerImple(com.arjuna.ats.arjuna.objectstore.TxLog txLog)
constructor for use by ATParticipantRecoveryModule and ATCoordinatorRecoveryModule
|
Modifier and Type | Method and Description |
---|---|
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
|
boolean |
deleteParticipantRecoveryRecord(String id)
remove any participant recovery record with the supplied id from persistent storage
|
ATParticipantRecoveryRecord |
findParticipantRecoveryRecord(String id)
see if a participant recovery record with a given id exists in the table of participants which
need to be recreated following recovery
|
boolean |
isCoordinatorRecoveryStarted()
test whether the first AT coordinator recovery scan has completed.
|
boolean |
isParticipantPresent(com.arjuna.ats.arjuna.common.Uid uid)
test whether the supplied uid identifies an active participant or a recovered but inactive
participant
n.b.
|
boolean |
isParticipantRecoveryStarted()
test whether the first AT participant recovery scan has completed.
|
static boolean |
isRecoveryManagerInitialised() |
boolean |
isSubordinateCoordinatorRecoveryStarted()
test whether the first AT subordinate coordinator recovery scan has completed.
|
void |
recoverParticipants()
process all entries in the recovered participant map and attempt to recreate the
application participant and activate it
|
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
|
void |
setCoordinatorRecoveryStarted()
record the fact that the first AT coordinator recovery scan has completed.
|
void |
setSubordinateCoordinatorRecoveryStarted()
record the fact that the first AT subordinate coordinator recovery scan has completed.
|
void |
unregisterRecoveryModule(XTSATRecoveryModule module)
unregister an application specific recovery module previously registered as
a helper to recretae WS-AT durable participants
|
boolean |
writeParticipantRecoveryRecord(ATParticipantRecoveryRecord participantRecoveryRecord)
save the supplied participant recovery record to persistent storage
|
getRecoveryManager, setRecoveryManager
public XTSATRecoveryManagerImple(com.arjuna.ats.arjuna.objectstore.TxLog txLog)
txLog
- public static boolean isRecoveryManagerInitialised()
public void registerRecoveryModule(XTSATRecoveryModule module) throws NullPointerException
registerRecoveryModule
in class XTSATRecoveryManager
module
- the module which will be used to identify and recreate participants
for the applicationNullPointerException
- if the supplied module is nullpublic void unregisterRecoveryModule(XTSATRecoveryModule module) throws NoSuchElementException
unregisterRecoveryModule
in class XTSATRecoveryManager
module
- the module to be unregisteredNoSuchElementException
- if the module is not currently registeredpublic boolean writeParticipantRecoveryRecord(ATParticipantRecoveryRecord participantRecoveryRecord)
writeParticipantRecoveryRecord
in class XTSATRecoveryManager
participantRecoveryRecord
- public boolean deleteParticipantRecoveryRecord(String id)
deleteParticipantRecoveryRecord
in class XTSATRecoveryManager
id
- the id of the participant whose recovery details are being deletedpublic boolean isParticipantPresent(com.arjuna.ats.arjuna.common.Uid uid)
isParticipantPresent
in class XTSATRecoveryManager
uid
- public void addParticipantRecoveryRecord(com.arjuna.ats.arjuna.common.Uid uid, ATParticipantRecoveryRecord participantRecoveryRecord)
addParticipantRecoveryRecord
in class XTSATRecoveryManager
uid
- the uid under which the participant was saved in the file storeparticipantRecoveryRecord
- the in-memory representation of the recovery record
saved to diskpublic ATParticipantRecoveryRecord findParticipantRecoveryRecord(String id)
findParticipantRecoveryRecord
in class XTSATRecoveryManager
id
- the identifier of the participant being soughtpublic void recoverParticipants()
recoverParticipants
in class XTSATRecoveryManager
public boolean isParticipantRecoveryStarted()
isParticipantRecoveryStarted
in class XTSATRecoveryManager
public boolean isCoordinatorRecoveryStarted()
isCoordinatorRecoveryStarted
in class XTSATRecoveryManager
public boolean isSubordinateCoordinatorRecoveryStarted()
isSubordinateCoordinatorRecoveryStarted
in class XTSATRecoveryManager
public void setCoordinatorRecoveryStarted()
setCoordinatorRecoveryStarted
in class XTSATRecoveryManager
public void setSubordinateCoordinatorRecoveryStarted()
setSubordinateCoordinatorRecoveryStarted
in class XTSATRecoveryManager
Copyright © 2019 JBoss by Red Hat. All rights reserved.