[camel] branch master updated: CAMEL-14146 - camel-hdfs - Consumer that splits with ChunkSize should add similar header info like the Splitter (#3360)

[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 872ff66  CAMEL-14146 - camel-hdfs - Consumer that splits with 
ChunkSize should add similar header info like the Splitter (#3360)
872ff66 is described below

commit 872ff668e32620d4026e17835a1cc4a931a316a9
Author: Marius Cornescu <marius_corne...@yahoo.com>
AuthorDate: Sat Nov 23 10:54:58 2019 +0100

    CAMEL-14146 - camel-hdfs - Consumer that splits with ChunkSize should add 
similar header info like the Splitter (#3360)
---
 .../test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java
 
b/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java
index 38aeb9f..47d8ef6 100644
--- 
a/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java
+++ 
b/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsConsumerTest.java
@@ -126,7 +126,6 @@ public class HdfsConsumerTest {
     }
 
     @Test
-    @Ignore("TODO: https://issues.apache.org/jira/browse/CAMEL-14211";)
     public void doPollFromExistingLocalFile() throws Exception {
         // given
         String hdfsPath = "hdfs://localhost/target/test/multiple-consumers";
@@ -137,6 +136,7 @@ public class HdfsConsumerTest {
         when(endpointConfig.isConnectOnStartup()).thenReturn(true);
         
when(endpointConfig.getFileSystemLabel(anyString())).thenReturn("TEST_FS_LABEL");
         when(endpointConfig.getChunkSize()).thenReturn(100 * 1000);
+        when(endpointConfig.getMaxMessagesPerPoll()).thenReturn(10);
         when(endpoint.getCamelContext()).thenReturn(context);
         when(endpoint.createExchange()).thenReturn(new 
DefaultExchange(context));
         when(endpoint.getEndpointUri()).thenReturn(hdfsPath);
@@ -176,7 +176,6 @@ public class HdfsConsumerTest {
     }
 
     @Test
-    @Ignore("TODO: https://issues.apache.org/jira/browse/CAMEL-14211";)
     public void doPollFromExistingLocalFileWithStreamDownload() throws 
Exception {
         // given
         String hdfsPath = "hdfs://localhost/target/test/multiple-consumers";
@@ -188,6 +187,7 @@ public class HdfsConsumerTest {
         
when(endpointConfig.getFileSystemLabel(anyString())).thenReturn("TEST_FS_LABEL");
         when(endpointConfig.getChunkSize()).thenReturn(100 * 1000);
         when(endpointConfig.isStreamDownload()).thenReturn(true);
+        when(endpointConfig.getMaxMessagesPerPoll()).thenReturn(10);
         when(endpoint.getCamelContext()).thenReturn(context);
         when(endpoint.createExchange()).thenReturn(new 
DefaultExchange(context));
         when(endpoint.getEndpointUri()).thenReturn(hdfsPath);