Repository: camel Updated Branches: refs/heads/master 81d27e80f -> 3eb353a2c
CAMEL-7264 Added file path header when HDFS consumer pull the message Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3eb353a2 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3eb353a2 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3eb353a2 Branch: refs/heads/master Commit: 3eb353a2c87a93e5bf9c527e33e801968ddf7c39 Parents: 81d27e8 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Wed Mar 5 11:16:12 2014 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Wed Mar 5 11:16:44 2014 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/camel/component/hdfs/HdfsConsumer.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3eb353a2/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConsumer.java b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConsumer.java index 84c7e92..2c78740 100644 --- a/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConsumer.java +++ b/components/camel-hdfs/src/main/java/org/apache/camel/component/hdfs/HdfsConsumer.java @@ -138,6 +138,7 @@ public final class HdfsConsumer extends ScheduledPollConsumer { Message message = new DefaultMessage(); String fileName = StringUtils.substringAfterLast(status.getPath().toString(), "/"); message.setHeader(Exchange.FILE_NAME, fileName); + message.setHeader(Exchange.FILE_PATH, status.getPath().toString()); if (key.value != null) { message.setHeader(HdfsHeader.KEY.name(), key.value); }