Package org.activiti.engine

Examples of org.activiti.engine.RuntimeService.signal()


    Mocks.register("mule", muleService);
   
    // Start process instance
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("open-account-mule");
   
    runtimeService.signal(processInstance.getId());
   
    Map<String, Object> variables = new HashMap<String, Object>();
    variables.put("approved", true);
   
    Task task = taskService.createTaskQuery().singleResult();
View Full Code Here


    Mocks.register("mule", muleService);
   
    // Start process instance
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("open-account-mule");
   
    runtimeService.signal(processInstance.getId());
   
    Map<String, Object> variables = new HashMap<String, Object>();
    variables.put("approved", false);
   
    Task task = taskService.createTaskQuery().singleResult();
View Full Code Here

    Mocks.register("camel", camelBehaviour);
   
    // Start process instance
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("open-account");
   
    runtimeService.signal(processInstance.getId());
   
    Map<String, Object> variables = new HashMap<String, Object>();
    variables.put("approved", true);
   
    Task task = taskService.createTaskQuery().singleResult();
View Full Code Here

    Mocks.register("camel", camelBehaviour);
   
    // Start process instance
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("open-account");
   
    runtimeService.signal(processInstance.getId());
   
    Map<String, Object> variables = new HashMap<String, Object>();
    variables.put("approved", false);
   
    Task task = taskService.createTaskQuery().singleResult();
View Full Code Here

  @Override
  public void notify(DelegateExecution execution) throws Exception {
    // TODO Auto-generated method stub
    EngineServices engineServices = execution.getEngineServices();
    RuntimeService runtimeService = engineServices.getRuntimeService();
    runtimeService.signal(execution.getId());
  }

}
View Full Code Here

            .activityId(activityId)
            .singleResult();
     
      // signal receive task and attach variables if available
      if (variables.size() > 0) {
        runtimeService.signal(execution.getId(), variables);
      } else {
        runtimeService.signal(execution.getId());
      }

      // set up and return response message
View Full Code Here

     
      // signal receive task and attach variables if available
      if (variables.size() > 0) {
        runtimeService.signal(execution.getId(), variables);
      } else {
        runtimeService.signal(execution.getId());
      }

      // set up and return response message
      responseJSON.put("success", true);
      return responseJSON;
View Full Code Here

    activityList = historyService.createHistoricActivityInstanceQuery().activityType("receiveTask").executionId(processInstance.getId()).list();
    assertEquals(1, activityList.size());
   
    // 触发receive task
    System.out.println("begin invoke receive task...");
    runtimeService.signal(processInstance.getId());
   
    // 验证是否已经结束
    long count = historyService.createHistoricProcessInstanceQuery().finished().count();
    assertEquals(1, count);
  }
View Full Code Here

          if (!StringUtils.equals(br,job.getLastBuildResult())){
            job.setLastBuildResult(br);
            JobMD.setJobs(execId,jobs);
          }
        }
        rtSvc.signal(execId);
      }
    }
   
    private void log(String msg){
      if (log != null) log.println(msg);
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.