com.arjuna.wst11.messaging.engines

Class ParticipantEngine

java.lang.Object

com.arjuna.wst11.messaging.engines.ParticipantEngine

All Implemented Interfaces:

ParticipantInboundEvents

public class ParticipantEngine
extends Object
implements ParticipantInboundEvents

The participant state engine

Author:

kevin

Constructor Summary

Constructors

Constructor and Description
ParticipantEngine(Participant participant, String id, State state, W3CEndpointReference coordinator, boolean recovered) Construct the engine for the participant in a specified state.
ParticipantEngine(Participant participant, String id, W3CEndpointReference coordinator) Construct the initial engine for the participant.

Method Summary

Modifier and Type	Method and Description
void	commit(Notification commit, MAP map, ArjunaContext arjunaContext) Handle the commit event.
void	earlyReadonly() Handle the early readonly event.
void	earlyRollback() Handle the early rollback event.
W3CEndpointReference	getCoordinator() Return the endpoint reference for the coordinator associated with this participant.
String	getId() Get the coordinator id.
boolean	isPersisted() Is the participant persisted to disk?
boolean	isRecovered() Is the participant recovered?
void	prepare(Notification prepare, MAP map, ArjunaContext arjunaContext) Handle the prepare event.
void	recovery() Handle the recovery event.
void	rollback(Notification rollback, MAP map, ArjunaContext arjunaContext) Handle the rollback event.
void	soapFault(SoapFault soapFault, MAP map, ArjunaContext arjunaContext) Handle the soap fault event.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParticipantEngine

public ParticipantEngine(Participant participant,
                         String id,
                         W3CEndpointReference coordinator)

Construct the initial engine for the participant.

Parameters:

participant - The participant.

id - The participant id.

coordinator - The coordinator endpoint reference.

ParticipantEngine

public ParticipantEngine(Participant participant,
                         String id,
                         State state,
                         W3CEndpointReference coordinator,
                         boolean recovered)

Construct the engine for the participant in a specified state.

Parameters:

participant - The participant.

id - The participant id.

state - The initial state.

coordinator - The coordinator endpoint reference.

Method Detail

commit

public void commit(Notification commit,
                   MAP map,
                   ArjunaContext arjunaContext)

Handle the commit event.

Specified by:

commit in interface ParticipantInboundEvents

Parameters:

commit - The commit notification.

map - The addressing context.

arjunaContext - The arjuna context. None -> None (send committed) Active -> Aborting (do nothing) Preparing -> Aborting (do nothing) PreparedSuccess -> Committing (initiate commit) Committing -> Committing (do nothing) Aborting -> Aborting (do nothing)

prepare

public void prepare(Notification prepare,
                    MAP map,
                    ArjunaContext arjunaContext)

Handle the prepare event.

Specified by:

prepare in interface ParticipantInboundEvents

Parameters:

prepare - The prepare notification.

map - The addressing context.

arjunaContext - The arjuna context. None -> None (send aborted) Active -> Preparing (execute prepare) Preparing -> Preparing (do nothing) PreparedSuccess -> PreparedSuccess (resend prepared) Committing -> Committing (ignore) Aborting -> Aborting (send aborted and forget)

rollback

public void rollback(Notification rollback,
                     MAP map,
                     ArjunaContext arjunaContext)

Handle the rollback event.

Specified by:

rollback in interface ParticipantInboundEvents

Parameters:

rollback - The rollback notification.

map - The addressing context.

arjunaContext - The arjuna context. None -> None (send aborted) Active -> Aborting (execute rollback, send aborted and forget) Preparing -> Aborting (execute rollback, send aborted and forget) PreparedSuccess -> Aborting (execute rollback, send aborted and forget) Committing -> Committing (ignore) Aborting -> Aborting (send aborted and forget)

earlyRollback

public void earlyRollback()

Handle the early rollback event. None -> None Active -> Aborting (execute rollback, send aborted and forget) Preparing -> Aborting (execute rollback, send aborted and forget) PreparedSuccess -> PreparedSuccess Committing -> Committing Aborting -> Aborting

earlyReadonly

public void earlyReadonly()

Handle the early readonly event. None -> None Active -> None (send ReadOnly) Preparing -> None (send ReadOnly) PreparedSuccess -> PreparedSuccess Committing -> Committing Aborting -> Aborting

recovery

public void recovery()

Handle the recovery event. None -> None Active -> Active Preparing -> Preparing Committing -> Committing PreparedSuccess -> PreparedSuccess (resend Prepared) Aborting -> Aborting

soapFault

public void soapFault(SoapFault soapFault,
                      MAP map,
                      ArjunaContext arjunaContext)

Handle the soap fault event.

Specified by:

soapFault in interface ParticipantInboundEvents

Parameters:

soapFault - The soap fault.

map - The addressing context.

arjunaContext - The arjuna context.

getId

public String getId()

Get the coordinator id.

Returns:

The coordinator id.

getCoordinator

public W3CEndpointReference getCoordinator()

Description copied from interface: ParticipantInboundEvents

Return the endpoint reference for the coordinator associated with this participant.

Specified by:

getCoordinator in interface ParticipantInboundEvents

Returns:

the coordinator endpoint reference

isPersisted

public boolean isPersisted()

Is the participant persisted to disk?

Returns:

true if persisted, false otherwise.

isRecovered

public boolean isRecovered()

Is the participant recovered?

Returns:

true if recovered, false otherwise.