You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by he...@apache.org on 2013/06/05 15:27:53 UTC
[1/2] git commit: [Spring Batch] Improved Javadoc.
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 <he...@gmail.com>
Authored: Wed Jun 5 15:26:58 2013 +0200
Committer: Henryk Konsek <he...@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()) {
[2/2] git commit: Merge remote-tracking branch 'origin/master'
Posted by he...@apache.org.
Merge remote-tracking branch 'origin/master'
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e5b9fd21
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e5b9fd21
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e5b9fd21
Branch: refs/heads/master
Commit: e5b9fd21c64b049a50a1133299cd9e45ea9903ff
Parents: c76d6da 71558f1
Author: Henryk Konsek <he...@gmail.com>
Authored: Wed Jun 5 15:27:29 2013 +0200
Committer: Henryk Konsek <he...@gmail.com>
Committed: Wed Jun 5 15:27:29 2013 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/StartupListener.java | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
----------------------------------------------------------------------