Examples of org.quartz.Job.execute()

org.quartz.Job.execute()

Called by the {@link Scheduler} when a {@link Trigger} fires that is associated with the Job.

The implementation may wish to set a {@link JobExecutionContext#setResult(Object) result} object on the {@link JobExecutionContext} before this method exits. The result itselfis meaningless to Quartz, but may be informative to {@link JobListener}s or {@link TriggerListener}s that are watching the job's execution.
@throws JobExecutionException if there is an exception while executing the job.

                    method = Job.class.getMethod("execute", JobExecutionContext.class);
                }


                endpoint.beforeDelivery(method);


                job.execute(execution);


            } catch (NoSuchMethodException e) {
                throw new IllegalStateException(e);
            } catch (ResourceException e) {
                throw new JobExecutionException(e);

View Full Code Here

                    method = Job.class.getMethod("execute", JobExecutionContext.class);
                }


                endpoint.beforeDelivery(method);


                job.execute(execution);


            } catch (NoSuchMethodException e) {
                throw new IllegalStateException(e);
            } catch (ResourceException e) {
                throw new JobExecutionException(e);

View Full Code Here

         MessageEndpointFactory endpointFactory = (MessageEndpointFactory)jobExecutionContext.getJobDetail().getJobDataMap().get("endpointFactory");
         endpoint = endpointFactory.createEndpoint(null);
         if (endpoint != null)
         {
            Job job = (Job) endpoint;
            job.execute(jobExecutionContext);
         }
         else
         {
            log.error("ENDPOINT IS NULL!!!!");
         }

View Full Code Here

                final JobExecutionContext context = new JobExecutionContext(this.scheduler, fireBundle, executor);


                this.executor.execute(new Runnable() {
                        public void run() {
                            try {
                                executor.execute(context);
                            } catch (JobExecutionException e) {
                                getLogger().error("Job '" + job + "' died.", e);
                            }
                        }
                    });

View Full Code Here

                long endTime = startTime;
                
                // execute the job
                try {
                    log.debug("Calling execute on job " + jobDetail.getFullName());
                    job.execute(jec);
                    endTime = System.currentTimeMillis();
                } catch (JobExecutionException jee) {
                    endTime = System.currentTimeMillis();
                    jobExEx = jee;
                    getLog().info("Job " + jobDetail.getFullName() +

View Full Code Here

                long endTime = startTime;


                // execute the job
                try {
                    log.debug("Calling execute on job " + jobDetail.getKey());
                    job.execute(jec);
                    endTime = System.currentTimeMillis();
                } catch (JobExecutionException jee) {
                    endTime = System.currentTimeMillis();
                    jobExEx = jee;
                    getLog().info("Job " + jobDetail.getKey() +

View Full Code Here


                this.executor.execute(new Runnable() {
                        public void run() {
                            // ((CronJob)job).execute(name);
                            try {
                                executor.execute(context);
                            } catch (JobExecutionException e) {
                                getLogger().error("Job '" + job + "' died.", e);
                            }
                        }
                    });

View Full Code Here


                this.executor.execute(new Runnable() {
                        public void run() {
                            // ((CronJob)job).execute(name);
                            try {
                                executor.execute(context);
                            } catch (JobExecutionException e) {
                                getLogger().error("Job '" + job + "' died.", e);
                            }
                        }
                    });

View Full Code Here

                final JobExecutionContext context = new JobExecutionContext(this.scheduler, fireBundle, executor);


                this.executor.execute(new Runnable() {
                        public void run() {
                            try {
                                executor.execute(context);
                            } catch (JobExecutionException e) {
                                getLogger().error("Job '" + job + "' died.", e);
                            }
                        }
                    });

View Full Code Here

                }


                endpoint = (MessageEndpoint) job;
                endpoint.beforeDelivery(method);


                job.execute(execution);


            } catch (NoSuchMethodException e) {
                throw new IllegalStateException(e);
            } catch (ResourceException e) {
                ex = new JobExecutionException(e);

View Full Code Here

0 1

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.