org.jboss.jbossts.xts.recovery.participant.at

Class ATParticipantRecoveryRecord

java.lang.Object

org.jboss.jbossts.xts.recovery.participant.at.ATParticipantRecoveryRecord

All Implemented Interfaces:

PersistableParticipant

Direct Known Subclasses:

ATParticipantRecoveryRecord

public abstract class ATParticipantRecoveryRecord
extends Object
implements PersistableParticipant

asbstract class used to implement save, recover and reactivate API for durable XTS participants. this is subclassed by both a 1.0 and a 1.1 specific class because the activate operation needs to create a participant engine appropriate to the protocol in use when the participant was saved.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	id
protected Durable2PCParticipant	participant

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ATParticipantRecoveryRecord(String id, Durable2PCParticipant participant) construct the protocol-independent part of a WS-AT participant recovery record

Method Summary

Modifier and Type	Method and Description
abstract void	activate() create a participant engine to manage commit or rollback processing for the participant and install it in the active participants table
String	getId()
abstract boolean	isActive() test whether a participant is currently activated with the id of this recovery record.
protected abstract void	restoreEndpointReference(com.arjuna.ats.arjuna.state.InputObjectState ios) restore the endpoint reference to the coordinator for this participant
boolean	restoreParticipant(XTSATRecoveryModule module) called during recovery processing to attempt to convert the restored application- specific recovery state back into a participant
boolean	restoreState(com.arjuna.ats.arjuna.state.InputObjectState ios) Restore the state of the particpant from the specified input object stream.
protected abstract void	saveEndpointReference(com.arjuna.ats.arjuna.state.OutputObjectState oos) save the endpoint reference to the coordinator for this participant
boolean	saveState(com.arjuna.ats.arjuna.state.OutputObjectState oos) Retrieve and save the state of the particpant to the specified input object stream.
static String	type()

Methods inherited from class java.lang.Object

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

Field Detail

participant

protected Durable2PCParticipant participant

id

protected String id

Constructor Detail

ATParticipantRecoveryRecord

protected ATParticipantRecoveryRecord(String id,
                                      Durable2PCParticipant participant)

construct the protocol-independent part of a WS-AT participant recovery record

Parameters:

id -

participant -

Method Detail

saveState

public final boolean saveState(com.arjuna.ats.arjuna.state.OutputObjectState oos)

Retrieve and save the state of the particpant to the specified input object stream.

Specified by:

saveState in interface PersistableParticipant

Parameters:

oos - The output output stream.

Returns:

true if persisted, false otherwise.

restoreState

public boolean restoreState(com.arjuna.ats.arjuna.state.InputObjectState ios)

Restore the state of the particpant from the specified input object stream.

Specified by:

restoreState in interface PersistableParticipant

Parameters:

ios - The Input object stream.

Returns:

true if restored, false otherwise.

restoreParticipant

public boolean restoreParticipant(XTSATRecoveryModule module)
                           throws Exception

called during recovery processing to attempt to convert the restored application- specific recovery state back into a participant

Parameters:

module - the XTS recovery module to be used to attempt the conversion

Returns:

whether the record could be restored using the XTSATRecoveryModule

Throws:

Exception

getId

public String getId()

type

public static String type()

Returns:

the path string under which AT participant records are to be located in the TX object store

saveEndpointReference

protected abstract void saveEndpointReference(com.arjuna.ats.arjuna.state.OutputObjectState oos)
                                       throws IOException,
                                              XMLStreamException

save the endpoint reference to the coordinator for this participant

Throws:

IOException

XMLStreamException

restoreEndpointReference

protected abstract void restoreEndpointReference(com.arjuna.ats.arjuna.state.InputObjectState ios)
                                          throws IOException,
                                                 XMLStreamException

restore the endpoint reference to the coordinator for this participant

Throws:

IOException

XMLStreamException

activate

public abstract void activate()

create a participant engine to manage commit or rollback processing for the participant and install it in the active participants table

isActive

public abstract boolean isActive()

test whether a participant is currently activated with the id of this recovery record.

Returns:

true if a participant is currently activated with the id of this recovery record