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:23:24 UTC
[2/2] git commit: CAMEL-7264 Added file path header when HDFS
consumer pull the message
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/d26d7c52
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/d26d7c52
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/d26d7c52
Branch: refs/heads/camel-2.11.x
Commit: d26d7c52fd926efd11f48e1e28b735dbb9443793
Parents: 5d183c8
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:22:38 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/d26d7c52/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 b24a9ea..4a28d20 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
@@ -139,6 +139,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);
}