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 org.apache.openejb.quartz.Scheduler.addJob()

                    final JobDetail job = JobBuilder.newJob(EjbTimeoutJob.class)
                        .withIdentity(OPENEJB_TIMEOUT_JOB_NAME, OPENEJB_TIMEOUT_JOB_GROUP_NAME)
                        .storeDurably(true)
                        .requestRecovery(false)
                        .build();
                    thisScheduler.addJob(job, true);
                } catch (final SchedulerException e) {
                    throw new OpenEJBRuntimeException("Fail to initialize the default scheduler", e);
                }


                if (!newInstance) {

View Full Code Here

Examples of org.apache.sling.commons.scheduler.Scheduler.addJob()

            try {
                if ( scheduleInfo.expression != null ) {
                    if ( this.logger.isDebugEnabled() ) {
                        this.logger.debug("Adding timed event " + config.get(JOB_TOPIC) + "(" + scheduleInfo.jobId + ")" + " with cron expression " + scheduleInfo.expression);
                    }
                    localScheduler.addJob(scheduleInfo.jobId, this, config, scheduleInfo.expression, false);
                } else if ( scheduleInfo.period != null ) {
                    if ( this.logger.isDebugEnabled() ) {
                        this.logger.debug("Adding timed event " + config.get(JOB_TOPIC) + "(" + scheduleInfo.jobId + ")" + " with period " + scheduleInfo.period);
                    }
                    localScheduler.addPeriodicJob(scheduleInfo.jobId, this, config, scheduleInfo.period, false);

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()

                        return JobResult.OK;
                    }
                });
        try {
            final JobManager jobManager = this.getJobManager();
            jobManager.addJob(TOPIC, "myid1", null);
            assertTrue("No event received in the given time.", cb.block(5));
            cb.reset();
            assertFalse("Unexpected event received in the given time.", cb.block(5));
        } finally {
            jcReg.unregister();

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()

                        return JobResult.FAILED;
                    }
                });
        try {
            final JobManager jobManager = this.getJobManager();
            jobManager.addJob(TOPIC, "myid3", null);
            cb.block();


            assertEquals(1, jobManager.findJobs(JobManager.QueryType.ALL, "sling/test", -1, (Map<String, Object>[])null).size());
            // job is currently sleeping, but force cancel always waits!
            final Event e = jobManager.findJob("sling/test", Collections.singletonMap(JobUtil.PROPERTY_JOB_NAME, (Object)"myid3"));

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()

                        return JobResult.FAILED;
                    }
                });
        try {
            final JobManager jobManager = this.getJobManager();
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"myid2"));
            cb.block();


            assertEquals(1, jobManager.findJobs(JobManager.QueryType.ALL, TOPIC, -1, (Map<String, Object>[])null).size());
            // job is currently waiting, therefore cancel fails
            final Job e1 = jobManager.getJob(TOPIC, Collections.singletonMap("id", (Object)"myid2"));

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()

                        return JobResult.OK;
                    }
                });
        try {
            final JobManager jobManager = this.getJobManager();
            final Job j = jobManager.addJob(TOPIC, null);
            cb.block();


            assertNotNull(jobManager.getJob(TOPIC, null));


            cb2.block(); // and continue job

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()

                        return JobResult.FAILED;
                    }
                });
        try {
            final JobManager jobManager = this.getJobManager();
            final Job job = jobManager.addJob(TOPIC, null);


            assertTrue("No event received in the given time.", cb.block(5));
            cb.reset();
            // the job is retried after two seconds, so we wait again
            assertTrue("No event received in the given time.", cb.block(5));

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()

                    }
                });


        final JobManager jobManager = this.getJobManager();
        try {
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"1"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"2"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"3"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"4"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"5"));

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()

                });


        final JobManager jobManager = this.getJobManager();
        try {
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"1"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"2"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"3"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"4"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"5"));


            int count = 0;

View Full Code Here

Examples of org.apache.sling.event.jobs.JobManager.addJob()


        final JobManager jobManager = this.getJobManager();
        try {
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"1"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"2"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"3"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"4"));
            jobManager.addJob(TOPIC, Collections.singletonMap("id", (Object)"5"));


            int count = 0;
            final long startTime = System.currentTimeMillis();

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.