@Test void testExecuteAdditionalProcessAction() { setRetryPhaseAdditionalProcessAction.executeAdditionalProcessAction(PROCESS_GUID); Mockito.verify(runtimeService) .setVariable(EXECUTION_WITH_DEADLETTER_JOBS_PROCESS_ID, Variables.STEP_PHASE.getName(), StepPhase.RETRY.name()); Mockito.verify(runtimeService, never()) .setVariable(EXECUTION_WITHOUT_DEADLETTER_JOBS_PROCESS_ID, Variables.STEP_PHASE.getName(), StepPhase.RETRY.name()); }
@Override public void executeAdditionalProcessAction(String processInstanceId) { flowableFacade.getActiveProcessExecutions(processInstanceId) .stream() .map(this::toExecutionEntityImpl) .filter(executionEntityImpl -> executionEntityImpl.getDeadLetterJobCount() > 0) .map(ExecutionEntityImpl::getProcessInstanceId) .forEach(this::setRetryPhaseForProcess); }
SetRetryPhaseAdditionalProcessAction implements AdditionalProcessAction { @Override public void executeAdditionalProcessAction(String processInstanceId) { flowableFacade.getActiveProcessExecutions(processInstanceId) .stream() .map(this::toExecutionEntityImpl) .filter(executionEntityImpl -> executionEntityImpl.getDeadLetterJobCount() > 0) .map(ExecutionEntityImpl::getProcessInstanceId) .forEach(this::setRetryPhaseForProcess); } }
SetRetryPhaseAdditionalProcessAction implements AdditionalProcessAction { @Override public void executeAdditionalProcessAction(String processInstanceId) { flowableFacade.getActiveProcessExecutions(processInstanceId) .stream() .map(this::toExecutionEntityImpl) .filter(executionEntityImpl -> executionEntityImpl.getDeadLetterJobCount() > 0) .map(ExecutionEntityImpl::getProcessInstanceId) .forEach(this::setRetryPhaseForProcess); } @Inject  SetRetryPhaseAdditionalProcessAction(FlowableFacade flowableFacade); }
SetRetryPhaseAdditionalProcessAction implements AdditionalProcessAction { @Override public void executeAdditionalProcessAction(String processInstanceId) { flowableFacade.getActiveProcessExecutions(processInstanceId) .stream() .map(this::toExecutionEntityImpl) .filter(executionEntityImpl -> executionEntityImpl.getDeadLetterJobCount() > 0) .map(ExecutionEntityImpl::getProcessInstanceId) .forEach(this::setRetryPhaseForProcess); } @Inject  SetRetryPhaseAdditionalProcessAction(FlowableFacade flowableFacade); @Override void executeAdditionalProcessAction(String processInstanceId); @Override Action getApplicableAction(); }
SetRetryPhaseAdditionalProcessAction implements AdditionalProcessAction { @Override public void executeAdditionalProcessAction(String processInstanceId) { flowableFacade.getActiveProcessExecutions(processInstanceId) .stream() .map(this::toExecutionEntityImpl) .filter(executionEntityImpl -> executionEntityImpl.getDeadLetterJobCount() > 0) .map(ExecutionEntityImpl::getProcessInstanceId) .forEach(this::setRetryPhaseForProcess); } @Inject  SetRetryPhaseAdditionalProcessAction(FlowableFacade flowableFacade); @Override void executeAdditionalProcessAction(String processInstanceId); @Override Action getApplicableAction();  }