bpmn/mso-infrastructure-bpmn/src/main/java/org/onap/so/bpmn/core/plugins/AsyncTaskExecutor.java

   1 package org.onap.so.bpmn.core.plugins;
   2
   3 import org.camunda.bpm.engine.delegate.ExecutionListener;
   4 import org.camunda.bpm.engine.impl.bpmn.parser.AbstractBpmnParseListener;
   5 import org.camunda.bpm.engine.impl.pvm.process.ActivityImpl;
   6 import org.camunda.bpm.engine.impl.pvm.process.ScopeImpl;
   7 import org.camunda.bpm.engine.impl.util.xml.Element;
   8 import org.springframework.stereotype.Component;
   9
  10 @Component
  11 public class AsyncTaskExecutor extends AbstractBpmnParseListener {
  12
  13     private void injectTaskExecutorExecutionListener(ActivityImpl activity) {
  14         activity.addListener(ExecutionListener.EVENTNAME_END, new AsyncTaskExecutorListener());
  15     }
  16
  17     @Override
  18     public void parseEndEvent(Element endEventElement, ScopeImpl scope, ActivityImpl activity) {
  19         injectTaskExecutorExecutionListener(activity);
  20     }
  21 }