nav[aria-label="Primary Navigation"] { padding: 0; & ul { list-style: none; width: 100%; display: flex; flex-direction: row; justify-content: start; align-items: start; gap: 30px; padding: 0; & li { margin: 0; } & ul li { list-style: none; } } }

As we transition to the new Hyland Community, some post links may be temporarily disrupted as we finalize redirects. We apologize for the inconvenience and are working to resolve this as quickly as possible. Details.

process terminated event?

m2spring

Is there a way I can register an event handler with the process engine to get called whenever a process finishes?
Currently I'm awkwardly polling the HistoryService for a given process ID to determine that a process finished.
Thanks!
-Max

Find more posts tagged with

Comments

frederikherema1

Look at http://activiti.org/userguide/index.html#executionListeners. You can easily add this to your BPMN file and allow any of your code to be run, once the process has been finished:

<br><process id="executionListenersProcess"><br>&nbsp; <br>&nbsp;&nbsp;&nbsp; <extensionElements><br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <activiti:executionListener class="org.activiti.examples.RecordProcessFinishedListener" event="end" /><br>&nbsp;&nbsp;&nbsp; </extensionElements><br>

m2spring

Frederik, thank you for your response.
While I still find it kind of awkward to having to manipulate the BPMN DOM at BPMN load time just to get my listener injected, I got it now working.
I've got a helper which attaches the BPMN parse listener to the engine:

<br>class JenkowEngine{<br><br>&nbsp;&nbsp;&nbsp; static ProcessEngine getEngine(){<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (engine == null){<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &hellip;<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ClassLoader peCL = JenkowEngine.class.getClassLoader();<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Thread.currentThread().setContextClassLoader(peCL);<br><br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ProcessEngineConfigurationImpl peCfg = (ProcessEngineConfigurationImpl)cfg;<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; List<BpmnParseListener> preParseListeners = peCfg.getPreParseListeners();<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; if (preParseListeners == null){<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; preParseListeners = new ArrayList<BpmnParseListener>();<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; peCfg.setPreParseListeners(preParseListeners);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; preParseListeners.add(new JenkowBpmnParseListener());<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; cfg.setClassLoader(peCL);<br><br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; engine = cfg.buildProcessEngine();&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return engine;<br>&nbsp;&nbsp;&nbsp; }<br>}<br>

A new method adds the execution listener:

<br>class JenkowBpmnParseListener extends AbstractBpmnParseListener{<br>&nbsp;&nbsp;&nbsp; &hellip; <br>&nbsp;&nbsp;&nbsp; @Override<br>&nbsp;&nbsp;&nbsp; public void parseProcess(Element el, ProcessDefinitionEntity processDefinition) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; processDefinition.addExecutionListener("end",new ProcessExecLogger(el.attribute("id")));<br>&nbsp;&nbsp;&nbsp; }<br>}<br>

The execution listener itself is the easy part.
(For some reason I'm unable to access the id of the process definition from DelegateExecution, I'm passing this around "by hand" as 'name'.)

<br>public class ProcessExecLogger implements ExecutionListener{<br>&nbsp;&nbsp;&nbsp; private String name;<br>&nbsp;&nbsp;&nbsp; <br>&nbsp;&nbsp;&nbsp; ProcessExecLogger(String name) {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.name = name;<br>&nbsp;&nbsp;&nbsp; }<br><br>&nbsp;&nbsp;&nbsp; @Override<br>&nbsp;&nbsp;&nbsp; public void notify(DelegateExecution exec) throws Exception {<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("name&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; = "+name);<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("exec.getEventName()&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; -> "+exec.getEventName());<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("exec.getId()&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; -> "+exec.getId());<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("exec.getProcessBusinessKey() -> "+exec.getProcessBusinessKey());<br>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; System.out.println("exec.getProcessInstanceId()&nbsp; -> "+exec.getProcessInstanceId());<br>&nbsp;&nbsp;&nbsp; }<br>}<br>

It works, but does this make sense?
Thanks!
-Max

jbarrez

Looks good. That is exactly the use case why we added the bpmn parse listeners.