本文整理了Java中org.jbpm.workflow.core.impl.WorkflowProcessImpl
类的一些代码示例,展示了WorkflowProcessImpl
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkflowProcessImpl
类的具体详情如下:
包路径:org.jbpm.workflow.core.impl.WorkflowProcessImpl
类名称:WorkflowProcessImpl
[英]Default implementation of a RuleFlow process.
[中]规则流流程的默认实现。
代码示例来源:origin: kiegroup/jbpm
public Object start(final String uri, final String localName,
final Attributes attrs, final ExtensibleXmlParser parser)
throws SAXException {
parser.startElementBuilder(localName, attrs);
WorkflowProcessImpl process = (WorkflowProcessImpl) parser.getParent();
final String name = attrs.getValue("name");
final String type = attrs.getValue("importType");
final String location = attrs.getValue("location");
final String namespace = attrs.getValue("namespace");
emptyAttributeCheck(localName, "name", name, parser);
if (type != null && location != null && namespace != null) {
Map<String, String> typedImports = (Map<String, String>) process.getMetaData(type);
if (typedImports == null) {
typedImports = new HashMap<String, String>();
process.setMetaData(type, typedImports);
}
typedImports.put(namespace, location);
} else {
java.util.Set<String> list = process.getImports();
if (list == null) {
list = new HashSet<String>();
process.setImports(list);
}
list.add(name);
}
return null;
}
代码示例来源:origin: kiegroup/jbpm
private String generateRules(final Process process) {
StringBuffer builder = new StringBuffer();
if ( process instanceof WorkflowProcessImpl ) {
WorkflowProcessImpl ruleFlow = (WorkflowProcessImpl) process;
builder.append( "package " + ruleFlow.getPackageName() + "\n" );
Set<String> imports = ruleFlow.getImports();
if ( imports != null ) {
for ( String importString: imports ) {
builder.append( "import " + importString + ";\n" );
}
}
List<String> functionImports = ruleFlow.getFunctionImports();
if ( functionImports != null ) {
for ( String importString: functionImports ) {
builder.append( "import function " + importString + ";\n" );
}
}
Map<String, String> globals = ruleFlow.getGlobals();
if ( globals != null ) {
for ( Map.Entry<String, String> entry: globals.entrySet()) {
builder.append( "global " + entry.getValue() + " " + entry.getKey() + ";\n" );
}
}
Node[] nodes = ruleFlow.getNodes();
generateRules(nodes, process, builder);
}
return builder.toString();
}
代码示例来源:origin: kiegroup/jbpm
public Object start(final String uri,
final String localName,
final Attributes attrs,
final ExtensibleXmlParser parser) throws SAXException {
parser.startElementBuilder( localName, attrs );
WorkflowProcessImpl process = ( WorkflowProcessImpl ) parser.getParent();
final String identifier = attrs.getValue( "identifier" );
final String type = attrs.getValue( "type" );
emptyAttributeCheck( localName, "identifier", identifier, parser );
emptyAttributeCheck( localName, "type", type, parser );
Map<String, String> map = process.getGlobals();
if ( map == null ) {
map = new HashMap<String, String>();
process.setGlobals( map );
}
map.put( identifier, type );
return null;
}
代码示例来源:origin: kiegroup/jbpm
public Object start(final String uri,
final String localName,
final Attributes attrs,
final ExtensibleXmlParser parser) throws SAXException {
parser.startElementBuilder( localName,
attrs );
WorkflowProcessImpl process = ( WorkflowProcessImpl ) parser.getParent();
final String name = attrs.getValue( "name" );
emptyAttributeCheck( localName, "name", name, parser );
java.util.Set<String> list = process.getImports();
if ( list == null ) {
list = new HashSet<String>();
process.setImports( list );
}
list.add( name );
return null;
}
代码示例来源:origin: kiegroup/jbpm
processDescr.setName( "Process1" );
WorkflowProcessImpl process = new WorkflowProcessImpl();
process.setName( "Process1" );
process.setPackageName( "pkg1" );
代码示例来源:origin: kiegroup/jbpm
NodeInstanceFactoryRegistry.getInstance(ksession.getEnvironment()).register( mockNode.getClass(), factory );
WorkflowProcessImpl process = new WorkflowProcessImpl();
new ConnectionImpl(mockNode, Node.CONNECTION_DEFAULT_TYPE, endNode, Node.CONNECTION_DEFAULT_TYPE);
process.addNode( mockNode );
process.addNode( endNode );
代码示例来源:origin: org.jbpm/jbpm-workitems-webservice
List<Bpmn2Import> typedImports = (List<Bpmn2Import>) process.getMetaData("Bpmn2Imports");
代码示例来源:origin: kiegroup/jbpm
public Object start(final String uri,
final String localName,
final Attributes attrs,
final ExtensibleXmlParser xmlPackageReader) throws SAXException {
xmlPackageReader.startElementBuilder( localName,
attrs );
WorkflowProcessImpl process = ( WorkflowProcessImpl ) xmlPackageReader.getParent();
ActionNode actionNode = new ActionNode();
final String name = attrs.getValue( "name" );
emptyAttributeCheck( localName, "name", name, xmlPackageReader );
actionNode.setName( name );
final String id = attrs.getValue( "id" );
emptyAttributeCheck( localName, "id", name, xmlPackageReader );
actionNode.setId( new Long(id) );
process.addNode( actionNode );
((ProcessBuildData)xmlPackageReader.getData()).addNode( actionNode );
return actionNode;
}
代码示例来源:origin: kiegroup/jbpm
@Test
public void testAccept() {
KieBase kbase = KnowledgeBaseFactory.newKnowledgeBase();
KieSession ksession = kbase.newKieSession();
WorkflowProcessImpl process = new WorkflowProcessImpl();
RuleFlowProcessInstance processInstance = new RuleFlowProcessInstance();
processInstance.setState(ProcessInstance.STATE_ACTIVE);
processInstance.setProcess(process);
processInstance.setKnowledgeRuntime((InternalKnowledgeRuntime) ksession);
ProcessInstanceResolverStrategy strategy = new ProcessInstanceResolverStrategy();
assertTrue( strategy.accept(processInstance) );
Object object = new Object();
assertTrue( ! strategy.accept(object) );
}
代码示例来源:origin: kiegroup/jbpm
public WorkflowProcessImpl() {
nodeContainer = (org.jbpm.workflow.core.NodeContainer) createNodeContainer();
}
代码示例来源:origin: kiegroup/jbpm
public Object start(final String uri,
final String localName,
final Attributes attrs,
final ExtensibleXmlParser parser) throws SAXException {
parser.startElementBuilder( localName,
attrs );
WorkflowProcessImpl process = (WorkflowProcessImpl) parser.getParent();
final String name = attrs.getValue("name");
emptyAttributeCheck(localName, "name", name, parser);
SwimlaneContext swimlaneContext = (SwimlaneContext)
process.getDefaultContext(SwimlaneContext.SWIMLANE_SCOPE);
if (swimlaneContext != null) {
Swimlane swimlane = new Swimlane();
swimlane.setName(name);
swimlaneContext.addSwimlane(swimlane);
} else {
throw new SAXParseException(
"Could not find default swimlane context.", parser.getLocator());
}
return null;
}
代码示例来源:origin: kiegroup/jbpm
processDescr.setName("Process1");
WorkflowProcessImpl process = new WorkflowProcessImpl();
process.setName("Process1");
process.setPackageName("pkg1");
代码示例来源:origin: org.jbpm/jbpm-flow-builder
public Object start(final String uri,
final String localName,
final Attributes attrs,
final ExtensibleXmlParser parser) throws SAXException {
parser.startElementBuilder( localName,
attrs );
WorkflowProcessImpl process = ( WorkflowProcessImpl ) parser.getParent();
final String name = attrs.getValue( "name" );
emptyAttributeCheck( localName, "name", name, parser );
java.util.Set<String> list = process.getImports();
if ( list == null ) {
list = new HashSet<String>();
process.setImports( list );
}
list.add( name );
return null;
}
代码示例来源:origin: org.jbpm/jbpm-workitems-bpmn2
List<Bpmn2Import> typedImports = (List<Bpmn2Import>) process.getMetaData("Bpmn2Imports");
代码示例来源:origin: org.jbpm/jbpm-flow
public WorkflowProcessImpl() {
nodeContainer = (org.jbpm.workflow.core.NodeContainer) createNodeContainer();
}
代码示例来源:origin: org.jbpm/jbpm-flow-builder
public Object start(final String uri,
final String localName,
final Attributes attrs,
final ExtensibleXmlParser parser) throws SAXException {
parser.startElementBuilder( localName,
attrs );
WorkflowProcessImpl process = (WorkflowProcessImpl) parser.getParent();
final String name = attrs.getValue("name");
emptyAttributeCheck(localName, "name", name, parser);
SwimlaneContext swimlaneContext = (SwimlaneContext)
process.getDefaultContext(SwimlaneContext.SWIMLANE_SCOPE);
if (swimlaneContext != null) {
Swimlane swimlane = new Swimlane();
swimlane.setName(name);
swimlaneContext.addSwimlane(swimlane);
} else {
throw new SAXParseException(
"Could not find default swimlane context.", parser.getLocator());
}
return null;
}
代码示例来源:origin: org.jbpm/jbpm-bpmn2
public Object start(final String uri, final String localName,
final Attributes attrs, final ExtensibleXmlParser parser)
throws SAXException {
parser.startElementBuilder(localName, attrs);
WorkflowProcessImpl process = (WorkflowProcessImpl) parser.getParent();
final String name = attrs.getValue("name");
final String type = attrs.getValue("importType");
final String location = attrs.getValue("location");
final String namespace = attrs.getValue("namespace");
emptyAttributeCheck(localName, "name", name, parser);
if (type != null && location != null && namespace != null) {
Map<String, String> typedImports = (Map<String, String>) process.getMetaData(type);
if (typedImports == null) {
typedImports = new HashMap<String, String>();
process.setMetaData(type, typedImports);
}
typedImports.put(namespace, location);
} else {
java.util.Set<String> list = process.getImports();
if (list == null) {
list = new HashSet<String>();
process.setImports(list);
}
list.add(name);
}
return null;
}
代码示例来源:origin: org.jbpm/jbpm-flow-builder
private String generateRules(final Process process) {
StringBuffer builder = new StringBuffer();
if ( process instanceof WorkflowProcessImpl ) {
WorkflowProcessImpl ruleFlow = (WorkflowProcessImpl) process;
builder.append( "package " + ruleFlow.getPackageName() + "\n" );
Set<String> imports = ruleFlow.getImports();
if ( imports != null ) {
for ( String importString: imports ) {
builder.append( "import " + importString + ";\n" );
}
}
List<String> functionImports = ruleFlow.getFunctionImports();
if ( functionImports != null ) {
for ( String importString: functionImports ) {
builder.append( "import function " + importString + ";\n" );
}
}
Map<String, String> globals = ruleFlow.getGlobals();
if ( globals != null ) {
for ( Map.Entry<String, String> entry: globals.entrySet()) {
builder.append( "global " + entry.getValue() + " " + entry.getKey() + ";\n" );
}
}
Node[] nodes = ruleFlow.getNodes();
generateRules(nodes, process, builder);
}
return builder.toString();
}
代码示例来源:origin: kiegroup/jbpm
public Object start(final String uri,
final String localName,
final Attributes attrs,
final ExtensibleXmlParser parser) throws SAXException {
parser.startElementBuilder( localName,
attrs );
WorkflowProcessImpl process = ( WorkflowProcessImpl ) parser.getParent();
final String identifier = attrs.getValue( "identifier" );
final String type = attrs.getValue( "type" );
emptyAttributeCheck( localName, "identifier", identifier, parser );
emptyAttributeCheck( localName, "type", type, parser );
Map<String, String> map = process.getGlobals();
if ( map == null ) {
map = new HashMap<String, String>();
process.setGlobals( map );
}
map.put( identifier, type );
return null;
}
代码示例来源:origin: kiegroup/jbpm
processDescr.setName( "Process1" );
WorkflowProcessImpl process = new WorkflowProcessImpl();
process.setName( "Process1" );
process.setPackageName( "pkg1" );
内容来源于网络,如有侵权,请联系作者删除!