访问ProcessEventListener中的节点变量

Question

使用最新版本的6.2，对JBPM来说是相当新的。我正在尝试建立一个进程，通过该进程，我可以在打开某些（自定义）任务类型时调用遗留平台的REST API，并在它们完成时再次通过异步进程在未来的某个时间点。

在较高级别上，该过程应类似于：

旧版应用程序-

旧版应用程序-

我已经创建并注册了一个ProcessEventListener，并在AfterNode触发事件中创建了一个钩子来调用特定类型的节点。我还创建了一个自定义WorkItem定义并添加了可以在我注册的WorkItemHandler中访问的参数。我遇到的问题是我需要我的ProcessEventListener来检索我的WorkItem的每个实例（从旧版应用程序）的唯一ID，并在调用WorkItemHander之前将其附加到该WorkItem。我可以在WorkItemHandler中通过访问getParameter（'key'）来完成WorkItem，但我无法确定如何（或这是否可能）在ProcessEventListener中。

我可以（以及如何）：

1. 在ProcessEventListener中访问工作项（或用户任务）的参数
2. 确定ProcessEventListener中的节点类型（例如MyCustomTask与“用户任务”），以便仅为MyCustomTask调用此服务调用。我可以得到Node'event.getNodeInstance（）. getNode（）'，但我不能告诉节点类型是什么。
3. 如果远程服务出现任何错误（回滚到触发节点？），则阻止创建我的CustomTask。

我很确定答案是，我应该在WorkItemHandler中根据需要使用abortWorkItem（）执行这两个请求，但我无法确定如何作为WorkItemHandler解决方案的一部分处理相应的异步进程。

提前感谢任何反馈！

Answer 1

这是很多问题，但我会试一试。

是的，但只有在执行后，才可以满足您的要求。但这里仍然是：

public void afterNodeTriggered(ProcessNodeTriggeredEvent event){
......
  WorkItemNodeInstance wini=(WorkItemNodeInstance)event.getNodeInstance();
  wini.getWorkItem().getParameters()
.....

对

WorkItemNode node = (WorkItemNode)event.getNodeInstance().getNode();
if(node.getWork().getName().equals("MyCustomTask"){
  .....
}else if(node.getWork().getName().equals("Human Task"){
  ......
}

是的，但正如前面提到的，ProcessEventListener可能不是理想的地方。这并不适合胆小的人，但您可以在启动任何进程之前，在设置代码的某个地方提供自己的WorkItemNodeInstance实现，如下所示：

NodeInstanceFactoryRegistry.INSTANCE.register( WorkItemNode.class,new CreateNewNodeFactory( MyCustomWorkItemNodeInstance.class ) );

然后，您可能希望重写internalTrigger方法，根据您的需求，该方法可能如下所示：

public void internalTrigger(final NodeInstance from, String type) {
    try{
     /*my special custom code*/
        ....
        super.internalTrigger(from, type);
    }catch(MySpecialRemoteException e){
     /*my special custom exception handling*/
    }

根据您的要求，您可能还必须添加一个自定义ProcessInstanceMarshaller以确保持久进程实例化您的NodeInstance而不是默认进程，因此它确实变得棘手，但它是可行的：

ProcessMarshallerRegistry.INSTANCE.register(RuleFlowProcess.RULEFLOW_TYPE, new MyRuleflowProcessInstanceMarshaller());