public class InboundBridgeRecoveryManager extends Object implements XTSATRecoveryModule, com.arjuna.ats.arjuna.recovery.RecoveryModule, com.arjuna.ats.jta.recovery.XAResourceOrphanFilter
Constructor and Description |
---|
InboundBridgeRecoveryManager() |
Modifier and Type | Method and Description |
---|---|
com.arjuna.ats.jta.recovery.XAResourceOrphanFilter.Vote |
checkXid(Xid xid)
Used to identify inbound bridged Xids in either the RM log (when called by XARecoveryModule) or
the JCA subordinate tx log (when called internally from this class) which have or have not got a
remaining transaction that may still drive them to completion.
|
Durable2PCParticipant |
deserialize(String id,
ObjectInputStream objectInputStream)
Called during recovery processing to allow an application to identify a participant id
belonging to one of its participants and recreate the participant by deserializing
it from the supplied object input stream.
|
void |
endScan()
participant recovery modules may need to perform special processing when the a recovery scan has
completed.
|
void |
periodicWorkFirstPass()
Called by the RecoveryManager at start up, and then
PERIODIC_RECOVERY_PERIOD seconds after the completion, for all RecoveryModules,
of the second pass
|
void |
periodicWorkSecondPass()
Called by the RecoveryManager RECOVERY_BACKOFF_PERIOD seconds
after the completion of the first pass
|
Durable2PCParticipant |
recreate(String s,
byte[] bytes)
Unused recovery callback.
|
void |
start()
MC lifecycle callback, used to register components with the recovery manager.
|
void |
stop()
MC lifecycle callback, used to unregister components from the recovery manager.
|
public void start()
public void stop()
public Durable2PCParticipant deserialize(String id, ObjectInputStream objectInputStream) throws Exception
deserialize
in interface XTSATRecoveryModule
id
- the id used when the participant was createdobjectInputStream
- a stream from which the application should deserialize the participant
if it recognises that the id belongs to the module's applicationException
- if an error occurs deserializing the durable participantpublic void endScan()
endScan
in interface XTSATRecoveryModule
public Durable2PCParticipant recreate(String s, byte[] bytes) throws Exception
recreate
in interface XTSATRecoveryModule
s
- the id used when the participant was createdbytes
- a byte array returned form the original participant via a call to
method getRecoveryState of interface PersistableATParticipantException
- if an error occurs converting the recoveryState back to a
durable participantpublic void periodicWorkFirstPass()
periodicWorkFirstPass
in interface com.arjuna.ats.arjuna.recovery.RecoveryModule
public void periodicWorkSecondPass()
periodicWorkSecondPass
in interface com.arjuna.ats.arjuna.recovery.RecoveryModule
public com.arjuna.ats.jta.recovery.XAResourceOrphanFilter.Vote checkXid(Xid xid)
checkXid
in interface com.arjuna.ats.jta.recovery.XAResourceOrphanFilter
xid
- The in-doubt xid.Copyright © 2021 JBoss by Red Hat. All rights reserved.