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.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();
            do {

View Full Code Here

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

        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();
            do {
                count = finished.size() + cancelled.size();

View Full Code Here

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

            // we start 20 jobs, every second job has no processor
            final int COUNT = 20;
            for(int i = 0; i < COUNT; i++ ) {
                final String jobTopic = (i % 2 == 0 ? TOPIC : TOPIC + "2");


                jobManager.addJob(jobTopic, null);
            }
            while ( count.get() < COUNT / 2) {
                try {
                    Thread.sleep(100);
                } catch (InterruptedException ie) {

View Full Code Here

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

            props.put("int", new Integer(5));
            props.put("long", new Long(7));
            props.put("list", list);
            props.put("map", map);


            final String jobId = jobManager.addJob(TOPIC, props).getId();


            new RetryLoop(Conditions.collectionIsNotEmptyCondition(finishedEvents,
                    "Waiting for finishedEvents to have at least one element"), 5, 50);


            // no jobs queued, none processed and no available

View Full Code Here

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


            // we start a single job
            final Map<String, Object> props = new HashMap<String, Object>();
            props.put("dao", dao);


            final String id = jobManager.addJob(TOPIC + "/failed", props).getId();


            // wait until the conditions are met
            new RetryLoop(new RetryLoop.Condition() {


                @Override

View Full Code Here

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


        try {
            // we first sent one event to get the queue started
            final Map<String, Object> properties = new HashMap<String, Object>();
            properties.put("counter", -1);
            jobManager.addJob("sling/orderedtest/start", properties);
            assertTrue("No event received in the given time.", cb.block(5));
            cb.reset();


            // get the queue
            final Queue q = jobManager.getQueue("orderedtest");

View Full Code Here

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

            // we start "some" jobs:
            for(int i = 0; i < NUM_JOBS; i++ ) {
                final String subTopic = "sling/orderedtest/sub" + (i % 10);
                properties.clear();
                properties.put("counter", i);
                jobManager.addJob(subTopic, properties);
            }
            // start the queue
            q.resume();
            while ( count.get() < NUM_JOBS +1 ) {
                try {

View Full Code Here

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

                    }
                });


        try {
            // we first sent one event to get the queue started
            jobManager.addJob(TOPIC + "/start", null);
            assertTrue("No event received in the given time.", cb.block(5));
            cb.reset();


            // get the queue
            final Queue q = jobManager.getQueue(QUEUE_NAME);

View Full Code Here

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


            // we start "some" jobs:
            // first jobs without id
            for(int i = 0; i < NUM_JOBS; i++ ) {
                final String subTopic = TOPIC + "/sub" + (i % 10);
                jobManager.addJob(subTopic, null);
            }
            // second jobs with id
            for(int i = 0; i < NUM_JOBS; i++ ) {
                final String subTopic = TOPIC + "/sub" + (i % 10);
                jobManager.addJob(subTopic, "id" + i, null);

View Full Code Here

Examples of org.quartz.Scheduler.addJob()

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

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.