org.jbpm.workflow.core.impl.WorkflowProcessImpl类的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(11.0k)|赞(0)|评价(0)|浏览(74)

本文整理了Java中org.jbpm.workflow.core.impl.WorkflowProcessImpl类的一些代码示例,展示了WorkflowProcessImpl类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkflowProcessImpl类的具体详情如下:
包路径:org.jbpm.workflow.core.impl.WorkflowProcessImpl
类名称: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" );

相关文章