Polished example
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/112dff88 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/112dff88 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/112dff88 Branch: refs/heads/master Commit: 112dff88fcf54bce7d52e61a8758a856c9b37a7d Parents: 67ba6ff Author: Claus Ibsen <davscl...@apache.org> Authored: Thu Aug 7 11:17:29 2014 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu Aug 7 11:17:29 2014 +0200 ---------------------------------------------------------------------- .../example/pojo_messaging/DistributeRecordsBean.java | 9 ++++++++- .../pojo_messaging/SendFileRecordsToQueueBean.java | 11 +++++++++-- 2 files changed, 17 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/112dff88/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/DistributeRecordsBean.java ---------------------------------------------------------------------- diff --git a/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/DistributeRecordsBean.java b/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/DistributeRecordsBean.java index b1c2df7..d8071e2 100644 --- a/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/DistributeRecordsBean.java +++ b/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/DistributeRecordsBean.java @@ -19,17 +19,24 @@ package org.apache.camel.example.pojo_messaging; import org.apache.camel.Consume; import org.apache.camel.RecipientList; import org.apache.camel.language.XPath; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; //START SNIPPET: ex public class DistributeRecordsBean { + + private static final Logger LOG = LoggerFactory.getLogger(DistributeRecordsBean.class); + @Consume(uri = "activemq:personnel.records") @RecipientList public String[] route(@XPath("/person/city/text()") String city) { if (city.equals("London")) { + LOG.info("Person is from EMEA region"); return new String[] {"file:target/messages/emea/hr_pickup", "file:target/messages/emea/finance_pickup"}; } else { - return new String[] {"file:target/messages/amer/hr_pickup", + LOG.info("Person is from AMER region"); + return new String[] {"file:target/messages/amer/hr_pickup", "file:target/messages/amer/finance_pickup"}; } } http://git-wip-us.apache.org/repos/asf/camel/blob/112dff88/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/SendFileRecordsToQueueBean.java ---------------------------------------------------------------------- diff --git a/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/SendFileRecordsToQueueBean.java b/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/SendFileRecordsToQueueBean.java index 176893a..7eb935c 100644 --- a/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/SendFileRecordsToQueueBean.java +++ b/examples/camel-example-pojo-messaging/src/main/java/org/apache/camel/example/pojo_messaging/SendFileRecordsToQueueBean.java @@ -17,16 +17,23 @@ package org.apache.camel.example.pojo_messaging; import org.apache.camel.Consume; +import org.apache.camel.Header; import org.apache.camel.Produce; import org.apache.camel.ProducerTemplate; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; //START SNIPPET: ex public class SendFileRecordsToQueueBean { + + private static final Logger LOG = LoggerFactory.getLogger(SendFileRecordsToQueueBean.class); + @Produce(uri = "activemq:personnel.records") ProducerTemplate producer; - @Consume(uri = "file:src/data?noop=true&initialDelay=100&delay=100") - public void onFileSendToQueue(String body) { + @Consume(uri = "file:src/data?noop=true") + public void onFileSendToQueue(String body, @Header("CamelFileName") String name) { + LOG.info("Incoming file: {}", name); producer.sendBody(body); } }
