Repository: camel Updated Branches: refs/heads/master dc9144ecb -> b750c78a4
Fixed CS Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b750c78a Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b750c78a Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b750c78a Branch: refs/heads/master Commit: b750c78a4a33d15fb2394e2c94a0de845486a309 Parents: 3533c01 Author: Andrea Cosentino <anco...@gmail.com> Authored: Wed Feb 24 13:45:28 2016 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Wed Feb 24 13:45:40 2016 +0100 ---------------------------------------------------------------------- .../camel/component/quartz2/QuartzEndpoint.java | 38 ++++++++++---------- 1 file changed, 19 insertions(+), 19 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/b750c78a/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java b/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java index 7a6cd38..70b9631 100644 --- a/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java +++ b/components/camel-quartz2/src/main/java/org/apache/camel/component/quartz2/QuartzEndpoint.java @@ -301,18 +301,18 @@ public class QuartzEndpoint extends DefaultEndpoint { this.triggerKey = triggerKey; } - public Calendar getCustomCalendar() { - return customCalendar; - } + public Calendar getCustomCalendar() { + return customCalendar; + } /** * Specifies a custom calendar to avoid specific range of date */ - public void setCustomCalendar(Calendar customCalendar) { - this.customCalendar = customCalendar; - } + public void setCustomCalendar(Calendar customCalendar) { + this.customCalendar = customCalendar; + } - @Override + @Override public Producer createProducer() throws Exception { throw new UnsupportedOperationException("Quartz producer is not supported."); } @@ -459,8 +459,8 @@ public class QuartzEndpoint extends DefaultEndpoint { LOG.debug("Creating CronTrigger: {}", cron); String timeZone = (String)triggerParameters.get("timeZone"); if (timeZone != null) { - if (ObjectHelper.isNotEmpty(customCalendar)) { - result = TriggerBuilder.newTrigger() + if (ObjectHelper.isNotEmpty(customCalendar)) { + result = TriggerBuilder.newTrigger() .withIdentity(triggerKey) .startAt(startTime) .withSchedule(cronSchedule(cron) @@ -468,7 +468,7 @@ public class QuartzEndpoint extends DefaultEndpoint { .inTimeZone(TimeZone.getTimeZone(timeZone))) .modifiedByCalendar(QuartzConstants.QUARTZ_CAMEL_CUSTOM_CALENDAR) .build(); - } else { + } else { result = TriggerBuilder.newTrigger() .withIdentity(triggerKey) .startAt(startTime) @@ -476,25 +476,25 @@ public class QuartzEndpoint extends DefaultEndpoint { .withMisfireHandlingInstructionFireAndProceed() .inTimeZone(TimeZone.getTimeZone(timeZone))) .build(); - } + } jobDetail.getJobDataMap().put(QuartzConstants.QUARTZ_TRIGGER_CRON_TIMEZONE, timeZone); } else { - if (ObjectHelper.isNotEmpty(customCalendar)) { - result = TriggerBuilder.newTrigger() + if (ObjectHelper.isNotEmpty(customCalendar)) { + result = TriggerBuilder.newTrigger() .withIdentity(triggerKey) .startAt(startTime) .withSchedule(cronSchedule(cron) .withMisfireHandlingInstructionFireAndProceed()) .modifiedByCalendar(QuartzConstants.QUARTZ_CAMEL_CUSTOM_CALENDAR) .build(); - } else { + } else { result = TriggerBuilder.newTrigger() .withIdentity(triggerKey) .startAt(startTime) .withSchedule(cronSchedule(cron) .withMisfireHandlingInstructionFireAndProceed()) .build(); - } + } } // enrich job map with details @@ -519,19 +519,19 @@ public class QuartzEndpoint extends DefaultEndpoint { triggerParameters.put("repeatInterval", interval); } TriggerBuilder<SimpleTrigger> triggerBuilder; - if (ObjectHelper.isNotEmpty(customCalendar)) { - triggerBuilder = TriggerBuilder.newTrigger() + if (ObjectHelper.isNotEmpty(customCalendar)) { + triggerBuilder = TriggerBuilder.newTrigger() .withIdentity(triggerKey) .startAt(startTime) .withSchedule(simpleSchedule().withMisfireHandlingInstructionFireNow() .withRepeatCount(repeat).withIntervalInMilliseconds(interval)).modifiedByCalendar(QuartzConstants.QUARTZ_CAMEL_CUSTOM_CALENDAR); - } else { + } else { triggerBuilder = TriggerBuilder.newTrigger() .withIdentity(triggerKey) .startAt(startTime) .withSchedule(simpleSchedule().withMisfireHandlingInstructionFireNow() .withRepeatCount(repeat).withIntervalInMilliseconds(interval)); - } + } if (fireNow) { triggerBuilder = triggerBuilder.startNow();
