You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2014/03/05 04:18:06 UTC
git commit: CAMEL-7264 Added file path header when HDFS consumer pull
the message
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 <wi...@gmail.com>
Authored: Wed Mar 5 11:16:12 2014 +0800
Committer: Willem Jiang <wi...@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);
}