Return-Path: X-Original-To: apmail-camel-commits-archive@www.apache.org Delivered-To: apmail-camel-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CCE95D1E9 for ; Thu, 23 May 2013 21:47:32 +0000 (UTC) Received: (qmail 43296 invoked by uid 500); 23 May 2013 21:47:32 -0000 Delivered-To: apmail-camel-commits-archive@camel.apache.org Received: (qmail 43260 invoked by uid 500); 23 May 2013 21:47:32 -0000 Mailing-List: contact commits-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@camel.apache.org Delivered-To: mailing list commits@camel.apache.org Received: (qmail 43244 invoked by uid 99); 23 May 2013 21:47:32 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 23 May 2013 21:47:32 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 39396639C; Thu, 23 May 2013 21:47:32 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: cmueller@apache.org To: commits@camel.apache.org Date: Thu, 23 May 2013 21:47:32 -0000 Message-Id: <6b37ba21a5c940dea18a5b1d638f6cbb@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/3] git commit: added some debug statements to have the possibilities to check what's going on Updated Branches: refs/heads/master 6c3f812a5 -> adf8c4395 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/d1d9f4a4 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d1d9f4a4 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d1d9f4a4 Branch: refs/heads/master Commit: d1d9f4a4ad5ab1d5ead416dfc2b2ee24df9cba4c Parents: 6c3f812 Author: cmueller Authored: Thu May 23 23:44:38 2013 +0200 Committer: cmueller Committed: Thu May 23 23:44:38 2013 +0200 ---------------------------------------------------------------------- .../spring/batch/support/CamelItemProcessor.java | 9 ++++++++- .../spring/batch/support/CamelItemReader.java | 9 ++++++++- .../spring/batch/support/CamelItemWriter.java | 6 ++++++ .../batch/support/CamelJobExecutionListener.java | 8 ++++++++ 4 files changed, 30 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/d1d9f4a4/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 implements ItemProcessor { + 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 implements ItemProcessor { @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/d1d9f4a4/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 3c0a0db..221cba7 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 @@ -17,10 +17,14 @@ package org.apache.camel.component.spring.batch.support; import org.apache.camel.ConsumerTemplate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.batch.item.ItemReader; public class CamelItemReader implements ItemReader { + private static final transient Logger LOG = LoggerFactory.getLogger(CamelItemReader.class); + private final ConsumerTemplate consumerTemplate; private final String endpointUri; @@ -33,7 +37,10 @@ public class CamelItemReader implements ItemReader { @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; } } http://git-wip-us.apache.org/repos/asf/camel/blob/d1d9f4a4/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 implements ItemWriter { + 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 implements ItemWriter { @Override public void write(List 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/d1d9f4a4/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 {