List of addJob() Examples

Examples of addJob()

ch.entwine.weblounge.common.site.Module.addJob()
Adds the job to the set of jobs. @param job the job to add
ch.ethz.vs.rowa.job.ClientRequests.addJob()
com.gentics.cr.util.indexing.IndexExtension.addJob()
Adds a job to the queue @param name the name of the job to add @throws NoSuchMethodException if no job with the given name was found
com.narirelays.ems.services.TaskScheduleManagementService.addJob()
com.projity.job.Job.addJob()
com.stella.framework.scheduler.RunScheduler.addJob()
com.stella.framework.scheduler.RunSchedulerImpl.addJob()
com.twitter.ambrose.hive.reporter.EmbeddedAmbroseHiveProgressReporter.addJob()
de.phleisch.app.itsucks.core.Dispatcher.addJob()
es.emergya.scheduler.CustomScheduler.addJob()
Schedule a job execution indefinitely every repeatInterval, with the given jobKey.
Note: To start execution call method start(). @param repeatInterval miliseconds between job executions. @param jobKey A name for the job. @param jobClass Class of the job to be executed. It must have a empty constructor. @throws SchedulerException if the job can't be scheduled. @author jlrodriguez @param < T>
games.stendhal.server.entity.npc.SpeakerNPC.addJob()
gri.tasks.managers.workflows.WorkflowSubmission.addJob()
jsprit.core.problem.VehicleRoutingProblem.Builder.addJob()
org.activiti.engine.impl.asyncexecutor.AcquiredJobEntities.addJob()
org.apache.crunch.impl.mr.exec.MRExecutor.addJob()
org.apache.hadoop.mapred.PoolManager.addJob()
Add a job in the appropriate pool
org.apache.hadoop.mapred.jobcontrol.JobControl.addJob()
Add a new job. @param aJob the the new job
org.apache.hadoop.mapreduce.lib.jobcontrol.JobControl.addJob()
Add a new controlled job. @param aJob the new controlled job
org.apache.hadoop.raid.DistBlockIntegrityMonitor.Worker.LostFileInfo.addJob()
org.apache.openejb.quartz.Scheduler.addJob()
org.apache.sling.commons.scheduler.Scheduler.addJob()
/ Schedule a time based job. Note that if a job with the same name has already been added, the old job is cancelled and this new job replaces the old job. @param name The name of the job - or null. If no name is specified it can't be cancelled. @param job The job to execute (either {@link Job} or {@link Runnable}). @param config An optional configuration object - this configuration is only passed to the job the job implements {@link Job}. @param schedulingExpression The time specification using a scheduling expression. @param canRunConcurrently Whether this job can run even if previous scheduled runs are still running. @throws IllegalArgumentException If the scheduling expression can't be parsed or if the job has not the correct type. @throws Exception If the job can't be scheduled. @deprecated Use {@link #schedule(Object,ScheduleOptions)} instead.
org.apache.sling.event.jobs.JobManager.addJob()
Add a new job If the topic is null or illegal, no job is created and null is returned. If properties are provided, all of them must be serializable. If there are non serializable objects in the properties, no job is created and null is returned. A job topic is a hierarchical name separated by dashes, each part has to start with a letter, allowed characters are letters, numbers and the underscore. The returned job object is a snapshot of the job state taken at the time of creation. Updates to the job state are not reflected and the client needs to get a new job object using the job id. If the queue for processing this job is configured to drop the job, null is returned as well. @param topic The required job topic. @param properties Optional job properties. The properties must be serializable. @return The new job - or null if the job could not be created. @since 1.2
org.quartz.Scheduler.addJob()

Add the given Job to the Scheduler - with no associated Trigger. The Job will be 'dormant' until it is scheduled with a Trigger, or Scheduler.triggerJob() is called for it.

The Job must by definition be 'durable', if it is not, SchedulerException will be thrown.
@throws SchedulerException if there is an internal Scheduler error, or if the Job is not durable, or a Job with the same name already exists, and replace is false.
org.springframework.data.mongodb.crossstore.test.Resume.addJob()

Examples of ch.entwine.weblounge.common.site.Module.addJob()

    }


    // jobs
    NodeList jobNodes = XPathHelper.selectList(config, "m:jobs/m:job", xpathProcessor);
    for (int i = 0; i < jobNodes.getLength(); i++) {
      module.addJob(QuartzJob.fromXml(jobNodes.item(i), xpathProcessor));
    }


    // options
    Node optionsNode = XPathHelper.select(config, "m:options", xpathProcessor);
    OptionsHelper.fromXml(optionsNode, module, xpathProcessor);

View Full Code Here

Examples of ch.ethz.vs.rowa.job.ClientRequests.addJob()

    synchronized(waitingJobList){
      ClientRequests crequest = waitingJobList.get(uuid);
      //System.out.println("running commit: "+crequest.isRunning());
      synchronized (crequest) {
        if(crequest.isRunning()){
          crequest.addJob(commitJob);
        }
        else{
          synchronized (jobList) {
            
            jobList.add(commitJob);

View Full Code Here

Examples of com.gentics.cr.util.indexing.IndexExtension.addJob()

            try {
              HashMap<String, IndexExtension> extensions = ((LuceneIndexLocation) loc).getExtensions();
              if (extensions.containsKey(sExt)) {
                IndexExtension extension = extensions.get(sExt);
                String job = request.getParameter("job");
                extension.addJob(job);
              }
            } catch (Exception ex) {
              LOGGER.info("Couldn not add extension Job");
            }
          }

View Full Code Here

Examples of com.narirelays.ems.services.TaskScheduleManagementService.addJob()

  }
  
  public String addJob(){
    TaskScheduleManagementService taskScheduleManagementService = (TaskScheduleManagementService)StorageService.ctx.getBean("taskScheduleManagementService");
    if(taskScheduleManagementService!=null){
      resultInfo = taskScheduleManagementService.addJob(request.getParameter("jobclass_id"),parameterMap);
    }
    return SUCCESS;
  }
  
  public String modifyJob(){

View Full Code Here

Examples of com.projity.job.Job.addJob()

            }
             setProgress(1.0f);
                  return null;
          }
          });
        job.addJob(importer.getImportFileJob());
          job.addRunnable(new JobRunnable("LocalAccess: loadProject.end",1.0f){
          public Object run() throws Exception{
              Project project=importer.getProject();
              project.setFileName(opt.getFileName()); //overrides project name
            if (MICROSOFT_PROJECT_IMPORTER.equals(opt.getImporter()))

View Full Code Here

Examples of com.stella.framework.scheduler.RunScheduler.addJob()

    
    JobImpl jobImpls[] = new JobImpl[testJobcount];
    
    for(int i = 0; i < testJobcount; i++) {
      jobImpls[i] = new DatastageJobImpl("job" + i);
      runScheduler.addJob(jobImpls[i]);
    }
    
    jobImpls[0].addDependantJob(jobImpls[2]);
    jobImpls[1].addDependantJob(jobImpls[2]);
    jobImpls[2].addDependantJob(jobImpls[3]);

View Full Code Here

Examples of com.stella.framework.scheduler.RunSchedulerImpl.addJob()

    
    JobImpl jobImpls[] = new JobImpl[testJobcount];
    
    for(int i = 0; i < testJobcount; i++) {
      jobImpls[i] = new DatastageJobImpl("job" + i);
      runScheduler.addJob(jobImpls[i]);
    }
    
    jobImpls[0].addDependantJob(jobImpls[2]);
    jobImpls[1].addDependantJob(jobImpls[2]);
    jobImpls[2].addDependantJob(jobImpls[3]);

View Full Code Here

Examples of com.twitter.ambrose.hive.reporter.EmbeddedAmbroseHiveProgressReporter.addJob()

            jobProgress.setReduceProgress(1.0f);
          }
          reporter.addCompletedJobIds(jobIDStr);
          job.setJobStats(counterValues, mappers, reducers);
          job.setConfiguration(((HiveConf) conf).getAllProperties());
          reporter.addJob(job);
        }
        else {
          event = new Event.JobProgressEvent(dagNode);
        }
        reporter.addJobIdToProgress(jobIDStr, getJobProgress());

View Full Code Here

Examples of de.phleisch.app.itsucks.core.Dispatcher.addJob()

    //create an initial job
    UrlDownloadJob job = jobFactory.createDownloadJob();
    job.setUrl(new URL("http://itsucks.sourceforge.net/"));
    job.setSavePath(new File("/tmp/crawl")); //change this for windows
    job.setIgnoreFilter(true);
    dispatcher.addJob(job);
    
    mLog.info("Start demo dispatcher");
    
    //start the dispatcher
    dispatcher.processJobs();

View Full Code Here

Examples of es.emergya.scheduler.CustomScheduler.addJob()

        try {
          p.load(new FileReader(job));
          String _class = p.get("CLASS").toString();


          Job plugin = (Job) Class.forName(_class).newInstance();
          scheduler.addJob((int) plugin.getFrequency(),
              plugin.getName(), plugin.getClass(),
              plugin.getParameters(), plugin.getListenerList());
        } catch (Throwable e) {
          LOG.error(
              "Error trying to load job " + job.getAbsolutePath(),

View Full Code Here

0 1 2 3 4 5 6 7

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.