You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/11/23 09:55:13 UTC
[camel] branch master updated: CAMEL-14146 - camel-hdfs - Consumer
that splits with ChunkSize should add similar header info like the Splitter
(#3360)
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 <ma...@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);