public class CoordinatorEngine extends Object implements com.arjuna.webservices11.wsat.CoordinatorInboundEvents
Constructor and Description |
---|
CoordinatorEngine(String id,
boolean durable,
W3CEndpointReference participant)
Construct the initial engine for the coordinator.
|
CoordinatorEngine(String id,
boolean durable,
W3CEndpointReference participant,
boolean recovered,
com.arjuna.webservices11.wsat.State state)
Construct the engine for the coordinator in a specified state.
|
Modifier and Type | Method and Description |
---|---|
void |
aborted(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification aborted,
org.jboss.ws.api.addressing.MAP map,
com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
Handle the aborted event.
|
com.arjuna.webservices11.wsat.State |
commit()
Handle the commit event.
|
void |
committed(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification committed,
org.jboss.ws.api.addressing.MAP map,
com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
Handle the committed event.
|
String |
getId()
Get the coordinator id.
|
W3CEndpointReference |
getParticipant()
Get the participant endpoint reference
|
com.arjuna.webservices11.wsat.State |
getState()
Retrieve the current state of this participant
|
boolean |
isDurable()
Is the participant durable?
|
boolean |
isReadOnly()
Was this a read only response?
|
boolean |
isRecovered()
Is the participant recovered?
|
com.arjuna.webservices11.wsat.State |
prepare()
Handle the prepare event.
|
void |
prepared(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification prepared,
org.jboss.ws.api.addressing.MAP map,
com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
Handle the prepared event.
|
void |
readOnly(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification readOnly,
org.jboss.ws.api.addressing.MAP map,
com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
Handle the readOnly event.
|
com.arjuna.webservices11.wsat.State |
rollback()
Handle the rollback event.
|
void |
soapFault(com.arjuna.webservices.SoapFault soapFault,
org.jboss.ws.api.addressing.MAP map,
com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
Handle the soap fault event.
|
public CoordinatorEngine(String id, boolean durable, W3CEndpointReference participant)
id
- The coordinator id.durable
- true if the participant is durable, false if volatile.participant
- The participant endpoint reference.public CoordinatorEngine(String id, boolean durable, W3CEndpointReference participant, boolean recovered, com.arjuna.webservices11.wsat.State state)
id
- The coordinator id.durable
- true if the participant is durable, false if volatile.participant
- The participant endpoint reference.state
- The initial state.public void aborted(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification aborted, org.jboss.ws.api.addressing.MAP map, com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
aborted
in interface com.arjuna.webservices11.wsat.CoordinatorInboundEvents
aborted
- The aborted notification.map
- The addressing context.arjunaContext
- The arjuna context.
None -> None (ignore)
Active -> Aborting (forget)
Preparing -> Aborting (forget)
PreparedSuccess -> PreparedSuccess (invalid state)
Committing -> Committing (invalid state)
Aborting -> Aborting (forget)public void committed(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification committed, org.jboss.ws.api.addressing.MAP map, com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
committed
in interface com.arjuna.webservices11.wsat.CoordinatorInboundEvents
committed
- The committed notification.map
- The addressing context.arjunaContext
- The arjuna context.
None -> None (ignore)
Active -> Aborting (invalid state)
Preparing -> Aborting (invalid state)
PreparedSuccess -> PreparedSuccess (invalid state)
Committing -> Committing (forget)
Aborting -> Aborting (invalid state)public void prepared(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification prepared, org.jboss.ws.api.addressing.MAP map, com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
prepared
in interface com.arjuna.webservices11.wsat.CoordinatorInboundEvents
prepared
- The prepared notification.map
- The addressing context.arjunaContext
- The arjuna context.
None -> Durable: (send rollback), Volatile: Invalid state: none
Active -> Aborting (invalid state)
Preparing -> PreparedSuccess (Record Vote)
PreparedSuccess -> PreparedSuccess (ignore)
Committing -> Committing (resend Commit)
Aborting -> Aborting (resend Rollback and forget)public void readOnly(org.oasis_open.docs.ws_tx.wsat._2006._06.Notification readOnly, org.jboss.ws.api.addressing.MAP map, com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
readOnly
in interface com.arjuna.webservices11.wsat.CoordinatorInboundEvents
readOnly
- The readOnly notification.map
- The addressing context.arjunaContext
- The arjuna context.
None -> None (ignore)
Active -> Active (forget)
Preparing -> Preparing (forget)
PreparedSuccess -> PreparedSuccess (invalid state)
Committing -> Committing (invalid state)
Aborting -> Aborting (forget)public void soapFault(com.arjuna.webservices.SoapFault soapFault, org.jboss.ws.api.addressing.MAP map, com.arjuna.webservices11.wsarj.ArjunaContext arjunaContext)
soapFault
in interface com.arjuna.webservices11.wsat.CoordinatorInboundEvents
soapFault
- The soap fault.map
- The addressing context.arjunaContext
- The arjuna context.public com.arjuna.webservices11.wsat.State prepare()
public com.arjuna.webservices11.wsat.State commit()
public com.arjuna.webservices11.wsat.State rollback()
public String getId()
public W3CEndpointReference getParticipant()
getParticipant
in interface com.arjuna.webservices11.wsat.CoordinatorInboundEvents
public boolean isDurable()
public boolean isRecovered()
public boolean isReadOnly()
public com.arjuna.webservices11.wsat.State getState()
Copyright © 2013. All rights reserved.