|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.arjuna.wst.messaging.engines.ParticipantEngine
public class ParticipantEngine
The participant state engine
Constructor Summary | |
---|---|
ParticipantEngine(Participant participant,
java.lang.String id,
com.arjuna.webservices.wsaddr.EndpointReferenceType coordinator)
Construct the initial engine for the participant. |
|
ParticipantEngine(Participant participant,
java.lang.String id,
com.arjuna.webservices.wsat.State state,
com.arjuna.webservices.wsaddr.EndpointReferenceType coordinator,
boolean recovered)
Construct the engine for the participant in a specified state. |
Method Summary | |
---|---|
void |
commit(com.arjuna.webservices.wsat.NotificationType commit,
com.arjuna.webservices.wsaddr.AddressingContext addressingContext,
com.arjuna.webservices.wsarj.ArjunaContext arjunaContext)
Handle the commit event. |
void |
earlyReadonly()
Handle the early readonly event. |
void |
earlyRollback()
Handle the early rollback event. |
java.lang.String |
getId()
Get the coordinator id. |
boolean |
isPersisted()
Is the participant persisted to disk? |
boolean |
isRecovered()
Is the participant recovered? |
void |
prepare(com.arjuna.webservices.wsat.NotificationType prepare,
com.arjuna.webservices.wsaddr.AddressingContext addressingContext,
com.arjuna.webservices.wsarj.ArjunaContext arjunaContext)
Handle the prepare event. |
void |
recovery()
Handle the recovery event. |
void |
rollback(com.arjuna.webservices.wsat.NotificationType rollback,
com.arjuna.webservices.wsaddr.AddressingContext addressingContext,
com.arjuna.webservices.wsarj.ArjunaContext arjunaContext)
Handle the rollback event. |
void |
soapFault(com.arjuna.webservices.SoapFault soapFault,
com.arjuna.webservices.wsaddr.AddressingContext addressingContext,
com.arjuna.webservices.wsarj.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 |
---|
public ParticipantEngine(Participant participant, java.lang.String id, com.arjuna.webservices.wsaddr.EndpointReferenceType coordinator)
participant
- The participant.id
- The participant id.coordinator
- The coordinator endpoint reference.public ParticipantEngine(Participant participant, java.lang.String id, com.arjuna.webservices.wsat.State state, com.arjuna.webservices.wsaddr.EndpointReferenceType coordinator, boolean recovered)
participant
- The participant.id
- The participant id.state
- The initial state.coordinator
- The coordinator endpoint reference.Method Detail |
---|
public void commit(com.arjuna.webservices.wsat.NotificationType commit, com.arjuna.webservices.wsaddr.AddressingContext addressingContext, com.arjuna.webservices.wsarj.ArjunaContext arjunaContext)
commit
in interface com.arjuna.webservices.wsat.ParticipantInboundEvents
commit
- The commit notification.addressingContext
- 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)public void prepare(com.arjuna.webservices.wsat.NotificationType prepare, com.arjuna.webservices.wsaddr.AddressingContext addressingContext, com.arjuna.webservices.wsarj.ArjunaContext arjunaContext)
prepare
in interface com.arjuna.webservices.wsat.ParticipantInboundEvents
prepare
- The prepare notification.addressingContext
- 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)public void rollback(com.arjuna.webservices.wsat.NotificationType rollback, com.arjuna.webservices.wsaddr.AddressingContext addressingContext, com.arjuna.webservices.wsarj.ArjunaContext arjunaContext)
rollback
in interface com.arjuna.webservices.wsat.ParticipantInboundEvents
rollback
- The rollback notification.addressingContext
- 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)public void earlyRollback()
public void earlyReadonly()
public void recovery()
public void soapFault(com.arjuna.webservices.SoapFault soapFault, com.arjuna.webservices.wsaddr.AddressingContext addressingContext, com.arjuna.webservices.wsarj.ArjunaContext arjunaContext)
soapFault
in interface com.arjuna.webservices.wsat.ParticipantInboundEvents
soapFault
- The soap fault.addressingContext
- The addressing context.arjunaContext
- The arjuna context.public java.lang.String getId()
public boolean isPersisted()
public boolean isRecovered()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |