camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [2/8] git commit: Polished example
Date Thu, 07 Aug 2014 14:48:23 GMT
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 <davsclaus@apache.org>
Authored: Thu Aug 7 11:17:29 2014 +0200
Committer: Claus Ibsen <davsclaus@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);
     }
 }


Mime
View raw message