org.kie.api.definition.process.Node.getNodeContainer()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(7.1k)|赞(0)|评价(0)|浏览(138)

本文整理了Java中org.kie.api.definition.process.Node.getNodeContainer()方法的一些代码示例,展示了Node.getNodeContainer()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.getNodeContainer()方法的具体详情如下:
包路径:org.kie.api.definition.process.Node
类名称:Node
方法名:getNodeContainer

Node.getNodeContainer介绍

[英]The NodeContainer this Node lives in.
[中]此节点所在的节点容器。

代码示例

代码示例来源:origin: kiegroup/jbpm

private boolean acceptsNoIncomingConnections(Node node) {
  NodeContainer nodeContainer = node.getNodeContainer();
  return nodeContainer instanceof DynamicNode ||
      (nodeContainer instanceof WorkflowProcess && ((WorkflowProcess) nodeContainer).isDynamic());
}

代码示例来源:origin: kiegroup/jbpm

private boolean acceptsNoOutgoingConnections(Node node) {
  NodeContainer nodeContainer = node.getNodeContainer();
  return nodeContainer instanceof DynamicNode ||
      (nodeContainer instanceof WorkflowProcess && ((WorkflowProcess) nodeContainer).isDynamic());
}

代码示例来源:origin: kiegroup/jbpm

while (!(match.getNodeContainer() instanceof Process)) {
  id = ":" + match.getId() + id;
  match = (Node) match.getNodeContainer();

代码示例来源:origin: kiegroup/jbpm

Stack<NodeInstance> generatedInstances = new Stack<NodeInstance>();
NodeContainer parentContainer = toCompensateNode.getNodeContainer();
while( !(parentContainer instanceof RuleFlowProcess) ) { 
  nestedNodes.add(parentContainer);
  parentContainer = ((Node) parentContainer).getNodeContainer();

代码示例来源:origin: kiegroup/jbpm

public static String getUniqueNodeId(Node node) {
  String result = (String) node.getMetaData().get("UniqueId");
  if (result != null) {
    return result;
  }
  result = node.getId() + "";
  NodeContainer nodeContainer = node.getNodeContainer();
  while (nodeContainer instanceof CompositeNode) {
    CompositeNode composite = (CompositeNode) nodeContainer;
    result = composite.getId() + "-" + result;
    nodeContainer = composite.getNodeContainer();
  }
  return "_" + result;
}

代码示例来源:origin: kiegroup/jbpm

public void validateAddIncomingConnection(final String type, final Connection connection) {
  CompositeNode.NodeAndType nodeAndType = internalGetLinkedIncomingNode(type);
  if (connection.getFrom().getNodeContainer() == this) {
    if (nodeAndType != null) {
      throw new IllegalArgumentException("Cannot link incoming connection type more than once: " + type);
    }
  } else {
    if (nodeAndType != null) {
      NodeImpl node = (NodeImpl) nodeAndType.getNode();
      if (node != null) {
        node.validateAddIncomingConnection(nodeAndType.getType(), connection);
      }
    }
  }
}

代码示例来源:origin: kiegroup/jbpm

if( completedIds.contains(((NodeImpl) handlerNode.getNodeContainer()).getMetaData("UniqueId")) ) { 
  NodeInstance subProcessNodeInstance 
    = ((NodeInstanceContainer) nodeInstanceContainer).getNodeInstance((Node) handlerNode.getNodeContainer());
  compensationInstances.add(subProcessNodeInstance);
  NodeInstance compensationHandlerNodeInstance

代码示例来源:origin: kiegroup/jbpm

public void validateAddOutgoingConnection(final String type, final Connection connection) {
  CompositeNode.NodeAndType nodeAndType = internalGetLinkedOutgoingNode(type);
  if (connection.getTo().getNodeContainer() == this) {
    if (nodeAndType != null) {
      throw new IllegalArgumentException("Cannot link outgoing connection type more than once: " + type);
    }
  } else {
    if (nodeAndType != null) {
      NodeImpl node = (NodeImpl) nodeAndType.getNode();
      if (node != null) {
        ((NodeImpl) nodeAndType.getNode()).validateAddOutgoingConnection(nodeAndType.getType(), connection);
      }
    }
  }
}

代码示例来源:origin: kiegroup/jbpm

public void triggerNode(long nodeId, boolean fireEvents) {
  org.jbpm.workflow.instance.NodeInstance nodeInstance = (org.jbpm.workflow.instance.NodeInstance)
    ((org.jbpm.workflow.instance.NodeInstanceContainer) getNodeInstanceContainer())
      .getNodeInstance(getNode().getNodeContainer().getNode(nodeId));
  triggerNodeInstance(nodeInstance, org.jbpm.workflow.core.Node.CONNECTION_DEFAULT_TYPE, fireEvents);
}

代码示例来源:origin: kiegroup/jbpm

NodeContainer nodeContainer = node.getNodeContainer();
while (nodeContainer instanceof CompositeNode) {
  CompositeNode parent = (CompositeNode) nodeContainer;

代码示例来源:origin: kiegroup/jbpm

NodeContainer targetParent = targetNode.getNodeContainer();
if( ! sourceParent.equals(targetParent) ) { 
  throw new IllegalArgumentException("Compensation Associations may not cross (sub-)process boundaries,");

代码示例来源:origin: kiegroup/jbpm

nodeId = (String)node.getMetaData().get("UniqueId");
  nodeType = node.getClass().getSimpleName();
  nodeContainerId = getNodeContainerId(node.getNodeContainer());
} else {
  nodeId = Long.toString(nodeInstance.getNodeId());

代码示例来源:origin: kiegroup/jbpm

nodeId = (String)node.getMetaData().get("UniqueId");
  nodeType = node.getClass().getSimpleName();
  nodeContainerId = getNodeContainerId(node.getNodeContainer());
} else {
  nodeId = Long.toString(nodeInstance.getNodeId());

代码示例来源:origin: kiegroup/jbpm

parentSubProcess = ((Node) subProcess).getNodeContainer();

代码示例来源:origin: kiegroup/jbpm

public void addIncomingConnection(String type, Connection connection) {
  if (connection.getFrom().getNodeContainer() == this) {
    linkOutgoingConnections(connection.getFrom().getId(), connection.getFromType(), org.jbpm.workflow.core.Node.CONNECTION_DEFAULT_TYPE);
  } else {
    super.addIncomingConnection(type, connection);
    CompositeNode.NodeAndType inNode = internalGetLinkedIncomingNode(type);
    if (inNode != null) {
      CompositeNodeStart start = new CompositeNodeStart(this, connection.getFrom(), type);
      internalAddNode(start);
      NodeImpl node = (NodeImpl) inNode.getNode();
      if (node != null) {
        new ConnectionImpl(
          start, org.jbpm.workflow.core.Node.CONNECTION_DEFAULT_TYPE, 
          inNode.getNode(), inNode.getType());
      }
    }
  }
}

代码示例来源:origin: kiegroup/jbpm

public void addOutgoingConnection(String type, Connection connection) {
  if (connection.getTo().getNodeContainer() == this) {
    linkIncomingConnections(
      org.jbpm.workflow.core.Node.CONNECTION_DEFAULT_TYPE,
      connection.getTo().getId(),    connection.getToType());            
  } else {
    super.addOutgoingConnection(type, connection);
    CompositeNode.NodeAndType outNode = internalGetLinkedOutgoingNode(type);
    if (outNode != null) {
      CompositeNodeEnd end = new CompositeNodeEnd(this, connection.getTo(), type);
      internalAddNode(end);
      NodeImpl node = (NodeImpl) outNode.getNode();
      if (node != null) {
        new ConnectionImpl(
          outNode.getNode(), outNode.getType(), 
          end, org.jbpm.workflow.core.Node.CONNECTION_DEFAULT_TYPE);
      }
    }
  }
}

代码示例来源:origin: org.jbpm/jbpm-flow

private boolean acceptsNoIncomingConnections(Node node) {
  NodeContainer nodeContainer = node.getNodeContainer();
  return nodeContainer instanceof DynamicNode ||
      (nodeContainer instanceof WorkflowProcess && ((WorkflowProcess) nodeContainer).isDynamic());
}

代码示例来源:origin: org.jbpm/jbpm-flow

private boolean acceptsNoOutgoingConnections(Node node) {
  NodeContainer nodeContainer = node.getNodeContainer();
  return nodeContainer instanceof DynamicNode ||
      (nodeContainer instanceof WorkflowProcess && ((WorkflowProcess) nodeContainer).isDynamic());
}

代码示例来源:origin: org.drools/knowledge-api

public NodeContainer getNodeContainer() {
  return new NodeContainerAdapter(delegate.getNodeContainer());
}

代码示例来源:origin: org.jbpm/jbpm-flow

public void triggerNode(long nodeId, boolean fireEvents) {
  org.jbpm.workflow.instance.NodeInstance nodeInstance = (org.jbpm.workflow.instance.NodeInstance)
    ((org.jbpm.workflow.instance.NodeInstanceContainer) getNodeInstanceContainer())
      .getNodeInstance(getNode().getNodeContainer().getNode(nodeId));
  triggerNodeInstance(nodeInstance, org.jbpm.workflow.core.Node.CONNECTION_DEFAULT_TYPE, fireEvents);
}

相关文章