Updated Branches: refs/heads/camel-2.11.x 9ac40a69d -> d3dcf50f4
added some debug statements to have the possibilities to check what's going on Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4e989fa6 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4e989fa6 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4e989fa6 Branch: refs/heads/camel-2.11.x Commit: 4e989fa69ab81f2f355e03f65548c6d847789a33 Parents: 9ac40a6 Author: cmueller <cmuel...@apache.org> Authored: Thu May 23 23:44:38 2013 +0200 Committer: cmueller <cmuel...@apache.org> Committed: Sat May 25 18:06:03 2013 +0200 ---------------------------------------------------------------------- .../spring/batch/support/CamelItemProcessor.java | 9 ++++++++- .../spring/batch/support/CamelItemReader.java | 10 ++++++++-- .../spring/batch/support/CamelItemWriter.java | 6 ++++++ .../batch/support/CamelJobExecutionListener.java | 8 ++++++++ 4 files changed, 30 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4e989fa6/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemProcessor.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemProcessor.java b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemProcessor.java index 5332c87..ec63bd1 100644 --- a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemProcessor.java +++ b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemProcessor.java @@ -17,10 +17,14 @@ package org.apache.camel.component.spring.batch.support; import org.apache.camel.ProducerTemplate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.batch.item.ItemProcessor; public class CamelItemProcessor<I, O> implements ItemProcessor<I, O> { + private static final transient Logger LOG = LoggerFactory.getLogger(CamelItemProcessor.class); + private final ProducerTemplate producerTemplate; private final String endpointUri; @@ -33,7 +37,10 @@ public class CamelItemProcessor<I, O> implements ItemProcessor<I, O> { @Override @SuppressWarnings("unchecked") public O process(I i) throws Exception { - return (O) producerTemplate.requestBody(endpointUri, i); + LOG.debug("processing item [{}]...", i); + O result = (O) producerTemplate.requestBody(endpointUri, i); + LOG.debug("processed item"); + return result; } } http://git-wip-us.apache.org/repos/asf/camel/blob/4e989fa6/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemReader.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemReader.java b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemReader.java index e54c64e..c337003 100644 --- a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemReader.java +++ b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemReader.java @@ -21,14 +21,17 @@ import org.apache.camel.ConsumerTemplate; import org.apache.camel.support.ServiceSupport; import org.apache.camel.util.ObjectHelper; import org.apache.camel.util.ServiceHelper; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.batch.item.ItemReader; import org.springframework.beans.factory.InitializingBean; public class CamelItemReader<I> extends ServiceSupport implements ItemReader<I>, InitializingBean { + private static final transient Logger LOG = LoggerFactory.getLogger(CamelItemReader.class); + private final CamelContext camelContext; private final ConsumerTemplate consumerTemplate; - private final String endpointUri; public CamelItemReader(ConsumerTemplate consumerTemplate, String endpointUri) { @@ -47,7 +50,10 @@ public class CamelItemReader<I> extends ServiceSupport implements ItemReader<I>, @Override @SuppressWarnings("unchecked") public I read() throws Exception { - return (I) consumerTemplate.receiveBody(endpointUri); + LOG.debug("reading new item..."); + I item = (I) consumerTemplate.receiveBody(endpointUri); + LOG.debug("read item [{}]", item); + return item; } @Override http://git-wip-us.apache.org/repos/asf/camel/blob/4e989fa6/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemWriter.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemWriter.java b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemWriter.java index e38d9fe..c65c283 100644 --- a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemWriter.java +++ b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelItemWriter.java @@ -19,10 +19,14 @@ package org.apache.camel.component.spring.batch.support; import java.util.List; import org.apache.camel.ProducerTemplate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.batch.item.ItemWriter; public class CamelItemWriter<I> implements ItemWriter<I> { + private static final transient Logger LOG = LoggerFactory.getLogger(CamelItemWriter.class); + private final ProducerTemplate producerTemplate; private final String endpointUri; @@ -35,7 +39,9 @@ public class CamelItemWriter<I> implements ItemWriter<I> { @Override public void write(List<? extends I> items) throws Exception { for (I item : items) { + LOG.debug("writing item [{}]...", item); producerTemplate.sendBody(endpointUri, item); + LOG.debug("wrote item"); } } http://git-wip-us.apache.org/repos/asf/camel/blob/4e989fa6/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java index 22b56db..de888bf 100644 --- a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java +++ b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java @@ -17,11 +17,15 @@ package org.apache.camel.component.spring.batch.support; import org.apache.camel.ProducerTemplate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.batch.core.JobExecution; import org.springframework.batch.core.JobExecutionListener; public class CamelJobExecutionListener implements JobExecutionListener { + private static final transient Logger LOG = LoggerFactory.getLogger(CamelJobExecutionListener.class); + private final ProducerTemplate producerTemplate; private final String endpointUri; @@ -33,12 +37,16 @@ public class CamelJobExecutionListener implements JobExecutionListener { @Override public void beforeJob(JobExecution jobExecution) { + LOG.debug("sending before job execution event [{}]...", jobExecution); producerTemplate.sendBodyAndHeader(endpointUri, jobExecution, EventType.HEADER_KEY, EventType.BEFORE.name()); + LOG.debug("sent before job execution event"); } @Override public void afterJob(JobExecution jobExecution) { + LOG.debug("sending after job execution event [{}]...", jobExecution); producerTemplate.sendBodyAndHeader(endpointUri, jobExecution, EventType.HEADER_KEY, EventType.AFTER.name()); + LOG.debug("sent after job execution event"); } public static enum EventType {
