本文整理了Java中org.kie.api.definition.process.Node.getNodeContainer()
方法的一些代码示例,展示了Node.getNodeContainer()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Node.getNodeContainer()
方法的具体详情如下:
包路径:org.kie.api.definition.process.Node
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!