Skip to content

Commit

Permalink
[revision]4d5521d3
Browse files Browse the repository at this point in the history
  • Loading branch information
shahryarSafizadeh committed Dec 30, 2023
1 parent 4d5521d commit 2f838eb
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,10 +31,10 @@ public class ExternalTaskResultAspect extends ExternalTaskBaseAspect {
@Around(value = "externalTaskHandler()")
public Object sendResults(ProceedingJoinPoint pjp) throws Throwable {
boolean convertToBpmnError = checkConvertToBpmnErrorInCaseOfIncident(pjp);
Object proceed = pjp.proceed();
Object[] args = pjp.getArgs();
ExternalTask externalTask = (ExternalTask) args[0];
try {
Object proceed = pjp.proceed();
Object[] args = pjp.getArgs();
ExternalTask externalTask = (ExternalTask) args[0];
if (Thread.currentThread().isInterrupted()) {
log.error("Thread has been interrupted before completion of task with business key:{}", externalTask.getBusinessKey());
throw new InterruptedException("Thread has been interrupted before completion.");
Expand All @@ -53,7 +53,7 @@ public Object sendResults(ProceedingJoinPoint pjp) throws Throwable {
CamundaClientRuntimeIncident runtimeIncident = (CamundaClientRuntimeIncident) e;
externalTaskResultUtil.handleException(runtimeIncident.getExceptionIncidentState(), e, pjp.getArgs(), convertToBpmnError);
} else if (e instanceof BpmnException) {
log.error("Bpmn exception happened for task with business key:{}", externalTask.getBusinessKey());
log.error("Bpmn exception happened while completing task.");
throw e;
} else {
externalTaskResultUtil.handleException(ExceptionIncidentState.NON_REPEATABLE, e, pjp.getArgs(), convertToBpmnError);
Expand Down

0 comments on commit 2f838eb

Please sign in to comment.