public class XTSBARecoveryManagerImple extends XTSBARecoveryManager
theRecoveryManager
Constructor and Description |
---|
XTSBARecoveryManagerImple(com.arjuna.ats.arjuna.objectstore.TxLog txLog)
constructor for use by BAParticipantRecoveryModule and BACoordinatorRecoveryModule
|
Modifier and Type | Method and Description |
---|---|
void |
addParticipantRecoveryRecord(com.arjuna.ats.arjuna.common.Uid uid,
BAParticipantRecoveryRecord 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
|
BAParticipantRecoveryRecord |
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 BA 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 BA participant recovery scan has completed.
|
static boolean |
isRecoveryManagerInitialised() |
boolean |
isSubordinateCoordinatorRecoveryStarted()
test whether the first BA 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(XTSBARecoveryModule module)
register an application specific recovery module which acts as a helper to recreate
a WS-BA durable participant from the participant's recovery data saved at prepare
|
void |
setCoordinatorRecoveryStarted()
record the fact that the first BA coordinator recovery scan has completed.
|
void |
setSubordinateCoordinatorRecoveryStarted()
record the fact that the first BA subordinate coordinator recovery scan has completed.
|
void |
unregisterRecoveryModule(XTSBARecoveryModule module)
unregister an application specific recovery module previously registered as
a helper to recretae WS-BA durable participants
|
boolean |
writeParticipantRecoveryRecord(BAParticipantRecoveryRecord participantRecoveryRecord)
save the supplied participant recovery record to persistent storage
|
getRecoveryManager, setRecoveryManager
public XTSBARecoveryManagerImple(com.arjuna.ats.arjuna.objectstore.TxLog txLog)
txLog
- public static boolean isRecoveryManagerInitialised()
public void registerRecoveryModule(XTSBARecoveryModule module) throws NullPointerException
registerRecoveryModule
in class XTSBARecoveryManager
module
- the module which will be used to identify and recreate participants
for the applicationNullPointerException
- if the supplied module is nullpublic void unregisterRecoveryModule(XTSBARecoveryModule module) throws NoSuchElementException
unregisterRecoveryModule
in class XTSBARecoveryManager
module
- the module to be unregisteredNoSuchElementException
- if the module is not currently registeredpublic boolean writeParticipantRecoveryRecord(BAParticipantRecoveryRecord participantRecoveryRecord)
writeParticipantRecoveryRecord
in class XTSBARecoveryManager
participantRecoveryRecord
- public boolean deleteParticipantRecoveryRecord(String id)
deleteParticipantRecoveryRecord
in class XTSBARecoveryManager
id
- the id of the participant whose recovery details are being deletedpublic boolean isParticipantPresent(com.arjuna.ats.arjuna.common.Uid uid)
isParticipantPresent
in class XTSBARecoveryManager
uid
- public void addParticipantRecoveryRecord(com.arjuna.ats.arjuna.common.Uid uid, BAParticipantRecoveryRecord participantRecoveryRecord)
addParticipantRecoveryRecord
in class XTSBARecoveryManager
uid
- the uid under which the participant was saved in the file storeparticipantRecoveryRecord
- the in-memory representation of the recovery record
saved to diskpublic BAParticipantRecoveryRecord findParticipantRecoveryRecord(String id)
findParticipantRecoveryRecord
in class XTSBARecoveryManager
id
- the identifier of the participant being soughtpublic void recoverParticipants()
recoverParticipants
in class XTSBARecoveryManager
public boolean isParticipantRecoveryStarted()
isParticipantRecoveryStarted
in class XTSBARecoveryManager
public boolean isCoordinatorRecoveryStarted()
isCoordinatorRecoveryStarted
in class XTSBARecoveryManager
public boolean isSubordinateCoordinatorRecoveryStarted()
XTSBARecoveryManager
isSubordinateCoordinatorRecoveryStarted
in class XTSBARecoveryManager
public void setCoordinatorRecoveryStarted()
setCoordinatorRecoveryStarted
in class XTSBARecoveryManager
public void setSubordinateCoordinatorRecoveryStarted()
XTSBARecoveryManager
setSubordinateCoordinatorRecoveryStarted
in class XTSBARecoveryManager
Copyright © 2017 JBoss by Red Hat. All rights reserved.