Examples of WorkflowInfo

de.scoopgmbh.copper.management.model.WorkflowInfo
gri.tasks.managers.workflows.WorkflowInfo
Data object which describes a workflow. This class is intended primarily for use with the WorkflowManager so that clients may query the status of their jobs. @author dan.rogers

Examples of de.scoopgmbh.copper.management.model.WorkflowInfo


  @Override
  public List<WorkflowInfo> queryWorkflowInstances() {
    List<WorkflowInfo> rv = new ArrayList<WorkflowInfo>(); 
    for (Workflow<?> wf : workflowMap.values()) {
      WorkflowInfo wfi = convert2Wfi(wf);
      rv.add(wfi);
    }
    logger.info("queryWorkflowInstances returned "+rv.size()+" instance(s)");
    return rv;
  }

View Full Code Here

Examples of de.scoopgmbh.copper.management.model.WorkflowInfo

  }
  
  protected WorkflowInfo convert2Wfi(Workflow<?> wf) {
    if (wf == null) 
      return null;
    WorkflowInfo wfi = new WorkflowInfo();
    wfi.setId(wf.getId());
    wfi.setPriority(wf.getPriority());
    wfi.setProcessorPoolId(wf.getProcessorPoolId());
    wfi.setState(wf.getProcessingState().name());
    wfi.setTimeout(null); // TODO
    return wfi;
  }

View Full Code Here

Examples of de.scoopgmbh.copper.management.model.WorkflowInfo

      
      engine.run(descr);
      
      Thread.sleep(1000L);
      
      WorkflowInfo info = engine.queryWorkflowInstance(descr.getId());
      
      assertNull(info);
    }
    finally {
      context.close();

View Full Code Here

Examples of de.scoopgmbh.copper.management.model.WorkflowInfo

      
      engine.run(descr);
      
      Thread.sleep(1000L);
      
      WorkflowInfo info = engine.queryWorkflowInstance(descr.getId());
      
      assertNull(info);
    }
    finally {
      context.close();

View Full Code Here

Examples of de.scoopgmbh.copper.management.model.WorkflowInfo


  @Override
  public List<WorkflowInfo> queryWorkflowInstances() {
    List<WorkflowInfo> rv = new ArrayList<WorkflowInfo>(); 
    for (Workflow<?> wf : workflowMap.values()) {
      WorkflowInfo wfi = convert2Wfi(wf);
      rv.add(wfi);
    }
    return rv;
  }

View Full Code Here

Examples of gri.tasks.managers.workflows.WorkflowInfo

            String xml = service.getWorkflowInfo(id);
            Document doc = buildXML(xml);
            throwExceptions(doc);
            
            Element rootElem = doc.getRootElement();
            WorkflowInfo info = serializers.getWorkflowInfoSerializer()
                .readWorkflowInfo(rootElem);
            return info;
        }
        catch(UnknownWorkflowException e) {
            throw new UnknownWorkflowException(id);

View Full Code Here

Examples of gri.tasks.managers.workflows.WorkflowInfo

            config.put("TASK_INFO_MANAGER", taskManager);
            config.put("WORKFLOW_MANAGER", this);
            config.put("WORKFLOW_MANAGER_SERVICE", this.service);
            config.put("WORKFLOW_ID", wkflId);
            
            WorkflowInfo info = getWorkflowInfo(wkflId);
            String taskId = info.getJobInfo(jobIndex).getTaskId();
                        
            JDOMSerializer serializer = serializers
                .getWorkflowSerializerSet(this)
                .getOutputParameterSerializer(jobIndex, taskId, config);

View Full Code Here

Examples of gri.tasks.managers.workflows.WorkflowInfo

  
  //process:
  try {
      
      WorkflowManager wkflManager = getWorkflowManager();
      WorkflowInfo wkflInfo = wkflManager.getWorkflowInfo(wkflId);
      String taskId = wkflInfo.getJobInfo(jobIndex).getTaskId();
      
      RunningJobInfo jobInfo = jobInfoManager.getJobInfo(wkflId);
                 
            //create serializer config:
            Map config = new HashMap();

View Full Code Here

Examples of gri.tasks.managers.workflows.WorkflowInfo

    
    // -------------------------------------------------------- Workflow Info
    
    public String getWorkflowInfo(String id) throws IOException {
        try {
            WorkflowInfo info = getWorkflowManager().getWorkflowInfo(id);
            
            Element elem = new Element("workflowInfo");
            serializers.getWorkflowInfoSerializer().write(info, elem);
            return xmlUtil.writeXML(elem);
        }

View Full Code Here

Examples of gri.tasks.managers.workflows.WorkflowInfo

  Element jobsElem = elem.getChild("jobs");
  if (jobsElem == null)
      throw new MissingElementException("jobs");
  List jobs = jobInfoListSerializer.readList(jobsElem);


        WorkflowInfo info = new WorkflowInfo(id, toInfoArray(jobs));
        
        //status:
        Element statusElem = elem.getChild("status");
  if (statusElem != null) {
      int status = Util.parseJobStatus(statusElem.getText());
      info.setStatus(status);
  }
        
        return info;
    }

View Full Code Here

TOP

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.