You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ha...@apache.org on 2009/01/28 00:25:14 UTC
svn commit: r738298 - in /camel/trunk/components/camel-quartz/src:
main/java/org/apache/camel/component/quartz/StatefulCamelJob.java
test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java
Author: hadrian
Date: Tue Jan 27 23:25:12 2009
New Revision: 738298
URL: http://svn.apache.org/viewvc?rev=738298&view=rev
Log:
A tiny bit of tab/whitespace cleanup.
Modified:
camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/StatefulCamelJob.java
camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java
Modified: camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/StatefulCamelJob.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/StatefulCamelJob.java?rev=738298&r1=738297&r2=738298&view=diff
==============================================================================
--- camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/StatefulCamelJob.java (original)
+++ camel/trunk/components/camel-quartz/src/main/java/org/apache/camel/component/quartz/StatefulCamelJob.java Tue Jan 27 23:25:12 2009
@@ -33,20 +33,18 @@
/* (non-Javadoc)
* @see org.quartz.Job#execute(org.quartz.JobExecutionContext)
*/
- public void execute(final JobExecutionContext context) throws JobExecutionException {
+ public void execute(final JobExecutionContext context) throws JobExecutionException {
- SchedulerContext schedulerContext;
- try {
- schedulerContext = context.getScheduler().getContext();
- }
- catch (SchedulerException e) {
- throw new JobExecutionException("Failed to obtain scheduler context for job " + context.getJobDetail().getName());
- }
-
- CamelContext camelContext = (CamelContext) schedulerContext.get(QuartzEndpoint.CONTEXT_KEY);
- String endpointUri = (String) context.getJobDetail().getJobDataMap().get(QuartzEndpoint.ENDPOINT_KEY);
- QuartzEndpoint quartzEndpoint = (QuartzEndpoint) camelContext.getEndpoint(endpointUri);
- quartzEndpoint.onJobExecute(context);
- }
+ SchedulerContext schedulerContext;
+ try {
+ schedulerContext = context.getScheduler().getContext();
+ } catch (SchedulerException e) {
+ throw new JobExecutionException("Failed to obtain scheduler context for job " + context.getJobDetail().getName());
+ }
+ CamelContext camelContext = (CamelContext) schedulerContext.get(QuartzEndpoint.CONTEXT_KEY);
+ String endpointUri = (String) context.getJobDetail().getJobDataMap().get(QuartzEndpoint.ENDPOINT_KEY);
+ QuartzEndpoint quartzEndpoint = (QuartzEndpoint) camelContext.getEndpoint(endpointUri);
+ quartzEndpoint.onJobExecute(context);
+ }
}
Modified: camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java?rev=738298&r1=738297&r2=738298&view=diff
==============================================================================
--- camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java (original)
+++ camel/trunk/components/camel-quartz/src/test/java/org/apache/camel/component/quartz/StatefulQuartzRouteTest.java Tue Jan 27 23:25:12 2009
@@ -49,19 +49,18 @@
}
- /* (non-Javadoc)
- * @see org.apache.camel.ContextTestSupport#createRouteBuilder()
- */
- @Override
- protected RouteBuilder createRouteBuilder() throws Exception {
- return new RouteBuilder() {
+ /* (non-Javadoc)
+ * @see org.apache.camel.ContextTestSupport#createRouteBuilder()
+ */
+ @Override
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
@Override
- public void configure() {
+ public void configure() {
// START SNIPPET: example
from("quartz://myGroup/myTimerName?trigger.repeatInterval=2&trigger.repeatCount=1&stateful=true").to("mock:result");
// END SNIPPET: example
}
};
- }
-
+ }
}