Package org.apache.oodt.cas.workflow.structs

Examples of org.apache.oodt.cas.workflow.structs.TaskJobInput


                taskJob.setLoadValue(new Integer(2));
                taskJob.setQueueName(task.getTaskConfig().getProperty(
                        QUEUE_NAME) != null ? task.getTaskConfig()
                        .getProperty(QUEUE_NAME) : DEFAULT_QUEUE_NAME);

                TaskJobInput in = new TaskJobInput();
                in.setDynMetadata(workflowInst.getSharedContext());
                in.setTaskConfig(task.getTaskConfig());
                in.setWorkflowTaskInstanceClassName(task
                        .getTaskInstanceClassName());

                workflowInst.setStatus(RESMGR_SUBMIT);
                persistWorkflowInstance();
View Full Code Here


                taskJob.setLoadValue(new Integer(2));
                taskJob.setQueueName(task.getTaskConfig().getProperty(
                        QUEUE_NAME) != null ? task.getTaskConfig()
                        .getProperty(QUEUE_NAME) : DEFAULT_QUEUE_NAME);

                TaskJobInput in = new TaskJobInput();
                in.setDynMetadata(workflowInst.getSharedContext());
                in.setTaskConfig(task.getTaskConfig());
                in.setWorkflowTaskInstanceClassName(task
                        .getTaskInstanceClassName());

                workflowInst.setStatus(RESMGR_SUBMIT);
                persistWorkflowInstance();
View Full Code Here

            Integer.parseInt(task.getTaskConfig().getProperty(TASK_LOAD)):new Integer(2));
        taskJob
            .setQueueName(task.getTaskConfig().getProperty(QUEUE_NAME) != null ? task
                .getTaskConfig().getProperty(QUEUE_NAME) : DEFAULT_QUEUE_NAME);

        TaskJobInput in = new TaskJobInput();
        in.setDynMetadata(workflowInst.getSharedContext());
        in.setTaskConfig(task.getTaskConfig());
        in.setWorkflowTaskInstanceClassName(task.getTaskInstanceClassName());

        workflowInst.setStatus(RESMGR_SUBMIT);
        persistWorkflowInstance();

        try {
View Full Code Here

    if (workflowTask.getTaskConfig().getProperty(TASK_LOAD) != null) {
      workflowTaskJob.setLoadValue(Integer.valueOf(workflowTask.getTaskConfig()
          .getProperty(TASK_LOAD)));
    }

    TaskJobInput in = new TaskJobInput();
    in.setDynMetadata(taskProcessor.getWorkflowInstance().getSharedContext());
    in.setTaskConfig(workflowTask.getTaskConfig());
    in.setWorkflowTaskInstanceClassName(workflowTask.getTaskInstanceClassName());

    try {
      this.currentJobId = rClient.submitJob(workflowTaskJob, in);
    } catch (JobExecutionException e) {
      LOG.log(Level.WARNING,
View Full Code Here

    if (workflowTask.getTaskConfig().getProperty(TASK_LOAD) != null) {
      workflowTaskJob.setLoadValue(Integer.valueOf(workflowTask.getTaskConfig()
          .getProperty(TASK_LOAD)));
    }

    TaskJobInput in = new TaskJobInput();
    in.setDynMetadata(dynMetadata);
    in.setTaskConfig(workflowTask.getTaskConfig());
    in.setWorkflowTaskInstanceClassName(workflowTask.getTaskInstanceClassName());

    try {
      this.currentJobId = rClient.submitJob(workflowTaskJob, in);
    } catch (JobExecutionException e) {
      LOG.log(Level.WARNING,
View Full Code Here

TOP

Related Classes of org.apache.oodt.cas.workflow.structs.TaskJobInput

Copyright © 2018 www.massapicom. 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.