This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch toD in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit e91437e2991ebc083a81f9051a68f2983b459444 Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Jun 8 14:46:59 2020 +0200 In case of Sink we need to use toD instead of to --- .../java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java | 2 +- .../apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java | 5 +++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java index 66f46fb..45ab9a9 100644 --- a/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java +++ b/core/src/main/java/org/apache/camel/kafkaconnector/utils/CamelMainSupport.java @@ -105,7 +105,7 @@ public class CamelMainSupport { } else { LOG.info("Creating Camel route from({}).to({})", fromUrl, toUrl); } - rd.to(toUrl); + rd.toD(toUrl); } }); } diff --git a/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java b/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java index eba4fb4..bd64d2a 100644 --- a/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java +++ b/tests/src/test/java/org/apache/camel/kafkaconnector/sink/file/CamelSinkFileITCase.java @@ -115,12 +115,13 @@ public class CamelSinkFileITCase extends AbstractKafkaTest { .withTopics(TestCommon.getDefaultTestTopic(this.getClass())) .withDirectoryName(SINK_DIR) .withFileName(FILENAME) - .withDoneFileName("${file:name}.done"); + .withDoneFileName("test.txt.done"); runTest(connectorPropertyFactory); } catch (Exception e) { LOG.error("HTTP test failed: {}", e.getMessage(), e); + System.err.println(e.getMessage()); fail(e.getMessage()); } } @@ -133,7 +134,7 @@ public class CamelSinkFileITCase extends AbstractKafkaTest { .withTopics(TestCommon.getDefaultTestTopic(this.getClass())) .withUrl(SINK_DIR) .append("fileName", FILENAME) - .append("doneFileName", "${file:name}.done") + .append("doneFileName", "test.txt.done") .buildUrl();
