public class CoordinatorCompletionParticipantEngine extends Object implements CoordinatorCompletionParticipantInboundEvents
Constructor and Description |
---|
CoordinatorCompletionParticipantEngine(String id,
W3CEndpointReference coordinator,
BusinessAgreementWithCoordinatorCompletionParticipant participant)
Construct the initial engine for the participant.
|
CoordinatorCompletionParticipantEngine(String id,
W3CEndpointReference coordinator,
BusinessAgreementWithCoordinatorCompletionParticipant participant,
State state,
boolean recovered)
Construct the engine for the participant in a specified state.
|
Modifier and Type | Method and Description |
---|---|
void |
cancel(NotificationType cancel,
MAP map,
ArjunaContext arjunaContext)
Handle the cancel event.
|
State |
cannotComplete()
Handle the cannot complete event.
|
void |
close(NotificationType close,
MAP map,
ArjunaContext arjunaContext)
Handle the close event.
|
void |
compensate(NotificationType compensate,
MAP map,
ArjunaContext arjunaContext)
Handle the compensate event.
|
void |
complete(NotificationType complete,
MAP map,
ArjunaContext arjunaContext)
Handle the complete event.
|
State |
completed()
Handle the completed event.
|
State |
exit()
Handle the exit event.
|
void |
exited(NotificationType exited,
MAP map,
ArjunaContext arjunaContext)
Handle the exited event.
|
State |
fail(QName exceptionIdentifier)
Handle the fail event.
|
void |
failed(NotificationType failed,
MAP map,
ArjunaContext arjunaContext)
Handle the failed event.
|
W3CEndpointReference |
getCoordinator()
Get the coordinator endpoint reference
|
String |
getId()
Get the coordinator id.
|
BusinessAgreementWithCoordinatorCompletionParticipant |
getParticipant()
Get the associated participant.
|
void |
getStatus(NotificationType getStatus,
MAP map,
ArjunaContext arjunaContext)
Handle the getStatus event.
|
boolean |
isRecovered()
check whether this participant's details have been recovered from the log
|
void |
notCompleted(NotificationType notCompleted,
MAP map,
ArjunaContext arjunaContext)
Handle the not completed event.
|
void |
recovery()
Handle the recovery event.
|
void |
soapFault(SoapFault soapFault,
MAP map,
ArjunaContext arjunaContext)
Handle the soap fault event.
|
void |
status(StatusType status,
MAP map,
ArjunaContext arjunaContext)
Handle the status event.
|
public CoordinatorCompletionParticipantEngine(String id, W3CEndpointReference coordinator, BusinessAgreementWithCoordinatorCompletionParticipant participant)
id
- The participant id.coordinator
- The coordinator endpoint reference.participant
- The participant.public CoordinatorCompletionParticipantEngine(String id, W3CEndpointReference coordinator, BusinessAgreementWithCoordinatorCompletionParticipant participant, State state, boolean recovered)
id
- The participant id.coordinator
- The coordinator endpoint reference.participant
- The participant.state
- The initial state.recovered
- true if the engine has been recovered from th elog otherwise falsepublic void cancel(NotificationType cancel, MAP map, ArjunaContext arjunaContext)
cancel
in interface CoordinatorCompletionParticipantInboundEvents
cancel
- The cancel notification.map
- The addressing context.arjunaContext
- The arjuna context.
Active -> Canceling
Canceling -> Canceling
Completing -> Canceling
Completed -> Completed (resend Completed)
Closing -> Closing
Compensating -> Compensating
Failing-Active -> Failing-Active (resend Fail)
Failing-Canceling -> Failing-Canceling (resend Fail)
Failing-Completing -> Failing-Completing (resend Fail)
Failing-Compensating -> Failing-Compensating
NotCompleting -> NotCompleting (resend CannotComplete)
Exiting -> Exiting (resend Exit)
Ended -> Ended (send Canceled)public void close(NotificationType close, MAP map, ArjunaContext arjunaContext)
close
in interface CoordinatorCompletionParticipantInboundEvents
close
- The close notification.map
- The addressing context.arjunaContext
- The arjuna context.
Active -> Active (invalid state)
Canceling -> Canceling (invalid state)
Completing -> Completing (invalid state)
Completed -> Closing
Closing -> Closing
Compensating -> Compensating (invalid state)
Failing-Active -> Failing-Active (invalid state)
Failing-Canceling -> Failing-Canceling (invalid state)
Failing-Completing -> Failing-Completing (invalid state)
Failing-Compensating -> Failing-Compensating (invalid state)
NotCompleting -> NotCompleting (invalid state)
Exiting -> Exiting (invalid state)
Ended -> Ended (send Closed)public void compensate(NotificationType compensate, MAP map, ArjunaContext arjunaContext)
compensate
in interface CoordinatorCompletionParticipantInboundEvents
compensate
- The compensate notification.map
- The addressing context.arjunaContext
- The arjuna context.
Active -> Active (invalid state)
Canceling -> Canceling (invalid state)
Completing -> Completing (invalid state)
Completed -> Compensating
Closing -> Closing (invalid state)
Compensating -> Compensating
Failing-Active -> Failing-Active (invalid state)
Failing-Canceling -> Failing-Canceling (invalid state)
Failing-Completing -> Failing-Completing (invalid state)
Failing-Compensating -> Failing-Compensating (resend Fail)
NotCompleting -> NotCompleting (invalid state)
Exiting -> Exiting (invalid state)
Ended -> Ended (send Compensated)public void complete(NotificationType complete, MAP map, ArjunaContext arjunaContext)
complete
in interface CoordinatorCompletionParticipantInboundEvents
complete
- The complete notification.map
- The addressing context.arjunaContext
- The arjuna context.
Active -> Completing
Canceling -> Canceling
Completing -> Completing
Completed -> Completed (resend Completed)
Closing -> Closing
Compensating -> Compensating
Failing-Active -> Failing-Active (resend Fail)
Failing-Canceling -> Failing-Canceling (resend Fail)
Failing-Completing -> Failing-Completing (resend Fail)
Failing-Compensating -> Failing-Compensating
NotCompleting -> NotCompleting (resend CannotComplete)
Exiting -> Exiting (resend Exit)
Ended -> Ended (send Fail)public void exited(NotificationType exited, MAP map, ArjunaContext arjunaContext)
exited
in interface CoordinatorCompletionParticipantInboundEvents
exited
- The exited notification.map
- The addressing context.arjunaContext
- The arjuna context.
Active -> Active (invalid state)
Canceling -> Canceling (invalid state)
Completing -> Completing (invalid state)
Completed -> Completed (invalid state)
Closing -> Closing (invalid state)
Compensating -> Compensating (invalid state)
Failing-Active -> Failing-Active (invalid state)
Failing-Canceling -> Failing-Canceling (invalid state)
Failing-Completing -> Failing-Completing (invalid state)
Failing-Compensating -> Failing-Compensating (invalid state)
NotCompleting -> NotCompleting (invalid state)
Exiting -> Ended
Ended -> Endedpublic void failed(NotificationType failed, MAP map, ArjunaContext arjunaContext)
failed
in interface CoordinatorCompletionParticipantInboundEvents
failed
- The failed notification.map
- The addressing context.arjunaContext
- The arjuna context.
Active -> Active (invalid state)
Canceling -> Canceling (invalid state)
Completing -> Completing (invalid state)
Completed -> Completed (invalid state)
Closing -> Closing (invalid state)
Compensating -> Compensating (invalid state)
Failing-Active -> Ended
Failing-Canceling -> Ended
Failing-Completing -> Ended
Failing-Compensating -> Ended
NotCompleting -> NotCompleting (invalid state)
Exiting -> Exiting (invalid state)
Ended -> Endedpublic void notCompleted(NotificationType notCompleted, MAP map, ArjunaContext arjunaContext)
notCompleted
in interface CoordinatorCompletionParticipantInboundEvents
notCompleted
- The not completed notification.map
- The addressing context.arjunaContext
- The arjuna context.
Active -> Active (invalid state)
Canceling -> Canceling (invalid state)
Completing -> Completing (invalid state)
Completed -> Completed (invalid state)
Closing -> Closing (invalid state)
Compensating -> Compensating (invalid state)
Failing-Active -> Failing-Active (invalid state)
Failing-Canceling -> Failing-Canceling (invalid state)
Failing-Completing -> Failing-Completing (invalid state)
Failing-Compensating -> Failing-Compensating (invalid state)
NotCompleting -> Ended
Exiting -> Exiting (invalid state)
Ended -> Endedpublic void getStatus(NotificationType getStatus, MAP map, ArjunaContext arjunaContext)
getStatus
in interface CoordinatorCompletionParticipantInboundEvents
getStatus
- The getStatus notification.map
- The addressing context.arjunaContext
- The arjuna context.public void status(StatusType status, MAP map, ArjunaContext arjunaContext)
status
in interface CoordinatorCompletionParticipantInboundEvents
status
- The status type.map
- The addressing context.arjunaContext
- The arjuna context.public void recovery()
public void soapFault(SoapFault soapFault, MAP map, ArjunaContext arjunaContext)
soapFault
in interface CoordinatorCompletionParticipantInboundEvents
soapFault
- The soap fault.map
- The addressing context.arjunaContext
- The arjuna context.public State completed()
public State exit()
public State fail(QName exceptionIdentifier)
public State cannotComplete()
public String getId()
public W3CEndpointReference getCoordinator()
public BusinessAgreementWithCoordinatorCompletionParticipant getParticipant()
public boolean isRecovered()
Copyright © 2017 JBoss by Red Hat. All rights reserved.