Updated Branches: refs/heads/master 71558f1ac -> e5b9fd21c
[Spring Batch] Improved Javadoc. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c76d6da6 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c76d6da6 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c76d6da6 Branch: refs/heads/master Commit: c76d6da6d88b99c9b3b1f9193e677dd4d38ca796 Parents: e8fdf3f Author: Henryk Konsek <hekon...@gmail.com> Authored: Wed Jun 5 15:26:58 2013 +0200 Committer: Henryk Konsek <hekon...@gmail.com> Committed: Wed Jun 5 15:26:58 2013 +0200 ---------------------------------------------------------------------- .../spring/batch/SpringBatchProducer.java | 11 +++++++++++ 1 files changed, 11 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/c76d6da6/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchProducer.java b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchProducer.java index 8f25f2a..970e4c6 100644 --- a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchProducer.java +++ b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/SpringBatchProducer.java @@ -28,6 +28,9 @@ import org.springframework.batch.core.JobParameters; import org.springframework.batch.core.JobParametersBuilder; import org.springframework.batch.core.launch.JobLauncher; +/** + * Spring Batch Producer triggering the execution of the jobs. + */ public class SpringBatchProducer extends DefaultProducer { private final JobLauncher jobLauncher; @@ -47,6 +50,14 @@ public class SpringBatchProducer extends DefaultProducer { exchange.getOut().setBody(jobExecution); } + /** + * Helper method converting the Camel message headers into the Spring Batch parameters map. Date, Long and Double + * header values are converted to the appropriate types. All the other header values are converted to string + * representation. + * + * @param headers Camel message header to be converted + * @return Camel message headers converted into the Spring Batch parameters map + */ protected JobParameters prepareJobParameters(Map<String, Object> headers) { JobParametersBuilder parametersBuilder = new JobParametersBuilder(); for (Map.Entry<String, Object> headerEntry : headers.entrySet()) {
