[camel] branch master updated: CAMEL-14021: Fix HDFS polling conumer message processing (#3213)

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new 9808b43  CAMEL-14021: Fix HDFS polling conumer message processing 
(#3213)
9808b43 is described below

commit 9808b43358a3fbda477f6f265d4b3f71cd23a086
Author: James Netherton <jamesnether...@users.noreply.github.com>
AuthorDate: Mon Sep 30 16:06:52 2019 +0100

    CAMEL-14021: Fix HDFS polling conumer message processing (#3213)
---
 .../src/main/java/org/apache/camel/component/hdfs/HdfsConsumer.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 7fb0288..9971f74 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
@@ -192,9 +192,9 @@ public final class HdfsConsumer extends 
ScheduledPollConsumer {
             if (log.isDebugEnabled()) {
                 log.debug("Skipping file: {} as not matching owner: {}", 
fileStatus.getPath(), config.getOwner());
             }
-            return true;
+            return false;
         }
-        return false;
+        return true;
     }
 
     private HdfsInputStream createInputStream(FileStatus fileStatus) {