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

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

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

Node.getIncomingConnections介绍

[英]The incoming connections for this Node. A Node could have multiple entry-points. This map contains the list of incoming connections for each entry-point.
[中]此节点的传入连接。一个节点可以有多个入口点。此映射包含每个入口点的传入连接列表。

代码示例

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

  1. private void visitConnections(Node[] nodes, StringBuilder xmlDump, int metaDataType) {
  2.   xmlDump.append("    <!-- connections -->" + EOL);
  3.   List<Connection> connections = new ArrayList<Connection>();
  4.   for (Node node: nodes) {
  5.     for (List<Connection> connectionList: node.getIncomingConnections().values()) {
  6.       connections.addAll(connectionList);
  7.     }
  8.   }
  9.   for (Connection connection: connections) {
  10.     visitConnection(connection, xmlDump, metaDataType);
  11.   }
  12.   xmlDump.append(EOL);
  13. }

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

  1. private void visitConnections(Node[] nodes, StringBuilder xmlDump, boolean includeMeta) {
  2.   List<Connection> connections = new ArrayList<Connection>();
  3.   for (Node node: nodes) {
  4.     for (List<Connection> connectionList: node.getIncomingConnections().values()) {
  5.       connections.addAll(connectionList);
  6.     }
  7.   }
  8.   xmlDump.append("  <connections>" + EOL);
  9.   for (Connection connection: connections) {
  10.     visitConnection(connection, xmlDump, includeMeta);
  11.   }
  12.   xmlDump.append("  </connections>" + EOL + EOL);
  13. }

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

  1. public List<Node> getAutoStartNodes() {
  2.   List<Node> nodes = Arrays.stream(getNodes())
  3.       .filter(n -> n.getIncomingConnections().isEmpty() && "true".equalsIgnoreCase((String)n.getMetaData().get("customAutoStart")))
  4.       .collect(Collectors.toList());
  5.       
  6.   return nodes;
  7. }

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

  1. public List<Node> getAutoStartNodes() {
  2.   if (!isDynamic()) {
  3.     return Collections.emptyList();
  4.   }
  5.   List<Node> nodes = Arrays.stream(getNodes())
  6.       .filter(n -> n.getIncomingConnections().isEmpty() && "true".equalsIgnoreCase((String)n.getMetaData().get("customAutoStart")))
  7.       .collect(Collectors.toList());
  8.   return nodes;
  9. }

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

  1. protected List<Connection> getSubConnections(CompositeNode compositeNode) {
  2.   List<Connection> connections = new ArrayList<Connection>();
  3.   for (org.kie.api.definition.process.Node subNode: compositeNode.getNodes()) {
  4.     // filter out composite start and end nodes as they can be regenerated
  5.     if (!(subNode instanceof CompositeNode.CompositeNodeEnd)) {
  6.       for (Connection connection: subNode.getIncomingConnections(Node.CONNECTION_DEFAULT_TYPE)) {
  7.         if (!(connection.getFrom() instanceof CompositeNode.CompositeNodeStart)) {
  8.           connections.add(connection);
  9.         }
  10.       }
  11.     }
  12.   }
  13.   return connections;
  14. }

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

  1. protected List<Connection> getSubConnections(CompositeNode compositeNode) {
  2.     List<Connection> connections = new ArrayList<Connection>();
  3.     for (org.kie.api.definition.process.Node subNode: compositeNode.getNodes()) {
  4.       // filter out composite start and end nodes as they can be regenerated
  5.       if (!(subNode instanceof CompositeNode.CompositeNodeEnd)) {
  6.         for (Connection connection: subNode.getIncomingConnections(Node.CONNECTION_DEFAULT_TYPE)) {
  7.           if (!(connection.getFrom() instanceof CompositeNode.CompositeNodeStart)) {
  8.             connections.add(connection);
  9.           }
  10.         }
  11.       }
  12.     }
  13.     return connections;
  14.   }
  15. }

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

  1. @Override
  2. public boolean acceptsEvent(String type, Object event, Function<String, String> resolver) {
  3.   if (type.equals(getActivationEventName())) {
  4.     return true;
  5.   }
  6.   for (Node node : getNodes()) {
  7.     if (resolver.apply(node.getName()).contains(type) && node.getIncomingConnections().isEmpty()) {
  8.       return true;
  9.     }
  10.   }
  11.   return super.acceptsEvent(type, event);
  12. }

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

  1. public boolean acceptsEvent(String type, Object event) {
  2.   if (type.equals(getActivationEventName())) {
  3.     return true;
  4.   }
  5.   for (Node node : getNodes()) {
  6.     if (type.equals(node.getName()) && node.getIncomingConnections().isEmpty()) {
  7.       return true;
  8.     }
  9.   }
  10.   return super.acceptsEvent(type, event);
  11. }

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

  1. protected void applyAsync(Node node, boolean isAsync) {
  2.   for (org.kie.api.definition.process.Node subNode: ((CompositeContextNode) node).getNodes()) {
  3.     if (isAsync) {
  4.       List<Connection> incoming = subNode.getIncomingConnections(NodeImpl.CONNECTION_DEFAULT_TYPE);
  5.       if (incoming != null) {
  6.         for (Connection con : incoming) {
  7.           if (con.getFrom() instanceof StartNode) {
  8.             ((Node)subNode).setMetaData("customAsync", Boolean.toString(isAsync));
  9.             return;
  10.           }
  11.         }
  12.       }
  13.       
  14.     }            
  15.   }
  16. }

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

  1. if (node.getIncomingConnections(NodeImpl.CONNECTION_DEFAULT_TYPE).isEmpty()) {
  2.   processNode(node,
  3.         processNodes);

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

  1. @Override
  2. public void signalEvent(String type, Object event) {
  3.   if (type.startsWith("RuleFlow-AdHocActivate")) {
  4.     if (event instanceof MatchCreatedEvent) {
  5.       Match match = ((MatchCreatedEvent) event).getMatch();                
  6.       match.getDeclarationIds().forEach(s -> this.setVariable(s.replaceFirst("\\$", ""), match.getDeclarationValue(s)));                
  7.     }            
  8.     trigger(null, org.jbpm.workflow.core.Node.CONNECTION_DEFAULT_TYPE);
  9.   } else if (getActivationEventType().equals(type)) {
  10.     if (event instanceof MatchCreatedEvent) {
  11.       matchCreated((MatchCreatedEvent) event);
  12.     }
  13.   } else {
  14.     super.signalEvent(type, event);
  15.     for (Node node: getCompositeNode().getNodes()) {
  16.       
  17.       if (type.equals(resolveVariable(node.getName())) && node.getIncomingConnections().isEmpty()) {
  18.         triggerSelectedNode(node, event);
  19.       }
  20.     }
  21.   }
  22. }

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

  1. public void assertNumOfIncommingConnections(ProcessInstance process,
  2.     String nodeName, int num) {
  3.   assertNodeExists(process, nodeName);
  4.   WorkflowProcessInstanceImpl instance = (WorkflowProcessInstanceImpl) process;
  5.   for (Node node : instance.getNodeContainer().getNodes()) {
  6.     if (node.getName().equals(nodeName)) {
  7.       if (node.getIncomingConnections().size() != num) {
  8.         fail("Expected incomming connections: " + num + " - found "
  9.             + node.getIncomingConnections().size());
  10.       } else {
  11.         break;
  12.       }
  13.     }
  14.   }
  15. }

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

  1. private void visitConnectionsDi(Node[] nodes, StringBuilder xmlDump) {
  2.   List<Connection> connections = new ArrayList<Connection>();
  3.   for (Node node: nodes) {
  4.     for (List<Connection> connectionList: node.getIncomingConnections().values()) {
  5.       connections.addAll(connectionList);

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

  1. public void validateRemoveIncomingConnection(final String type, final Connection connection) {
  2.   CompositeNode.NodeAndType nodeAndType = internalGetLinkedIncomingNode(type);
  3.   if (nodeAndType != null) {
  4.     for (Connection inConnection: nodeAndType.getNode().getIncomingConnections(nodeAndType.getType())) {
  5.       if (((CompositeNodeStart) inConnection.getFrom()).getInNodeId() == connection.getFrom().getId()) {
  6.         ((NodeImpl) nodeAndType.getNode()).validateRemoveIncomingConnection(nodeAndType.getType(), inConnection);
  7.         return;
  8.       }
  9.     }
  10.     throw new IllegalArgumentException(
  11.       "Could not find internal incoming connection for node");
  12.   }
  13. }

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

  1. public void removeIncomingConnection(String type, Connection connection) {
  2.   super.removeIncomingConnection(type, connection);
  3.   CompositeNode.NodeAndType nodeAndType = internalGetLinkedIncomingNode(type);
  4.   if (nodeAndType != null) {
  5.     for (Connection inConnection: nodeAndType.getNode().getIncomingConnections(nodeAndType.getType())) {
  6.       if (((CompositeNodeStart) inConnection.getFrom()).getInNodeId() == connection.getFrom().getId()) {
  7.         Node compositeNodeStart = inConnection.getFrom();
  8.         ((ConnectionImpl) inConnection).terminate();
  9.         internalRemoveNode(compositeNodeStart);
  10.         return;
  11.       }
  12.     }
  13.     throw new IllegalArgumentException(
  14.       "Could not find internal incoming connection for node");
  15.   }
  16. }

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

  1. if (type.equals(node.getName()) && node.getIncomingConnections().isEmpty()) {
  2.   NodeInstance nodeInstance = getNodeInstance(node);
  3.   if (event != null) {

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

  1. oldNodeAndType.getNode().getIncomingConnections(oldNodeAndType.getType());
  2. if (oldInConnections != null) {
  3.   for (Connection connection: new ArrayList<Connection>(oldInConnections)) {

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

  1. int level = ((org.jbpm.workflow.instance.NodeInstance)from).getLevel();
  2. ((org.jbpm.workflow.instance.NodeInstanceContainer)getNodeInstanceContainer()).setCurrentLevel(level);
  3. Collection<Connection> incoming = getNode().getIncomingConnections(type);
  4. for (Connection conn : incoming) {
  5.   if (conn.getFrom().getId() == from.getNodeId()) {

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

  1. List<Connection> connections = nodeAndType.getNode().getIncomingConnections(nodeAndType.getType());
  2. for (Iterator<Connection> iterator = connections.iterator(); iterator.hasNext(); ) {
  3.   Connection connection = iterator.next();

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

  1. public boolean acceptsEvent(String type, Object event) {
  2.   if (type.equals(getActivationEventName())) {
  3.     return true;
  4.   }
  5.   for (Node node : getNodes()) {
  6.     if (type.equals(node.getName()) && node.getIncomingConnections().isEmpty()) {
  7.       return true;
  8.     }
  9.   }
  10.   return super.acceptsEvent(type, event);
  11. }

内容来源于网络，如有侵权，请联系作者删除！

Node

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com