This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 74cffea Added test on different component properties formats fix #132
new fa66cd3 Merge pull request #187 from valdar/pathOptionsFix
74cffea is described below
commit 74cffea7b3f8810a16acd2980ba995cc6b4405f7
Author: Andrea Tarocchi <andrea.taroc...@gmail.com>
AuthorDate: Mon May 4 19:21:50 2020 +0200
Added test on different component properties formats fix #132
---
...derTest.java => PropertiesNameFormatsTest.java} | 23 +++++++++++++++++-----
.../camel/kafkaconnector/PropertiesOrderTest.java | 3 ++-
2 files changed, 20 insertions(+), 6 deletions(-)
diff --git
a/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesOrderTest.java
b/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesNameFormatsTest.java
similarity index 55%
copy from
core/src/test/java/org/apache/camel/kafkaconnector/PropertiesOrderTest.java
copy to
core/src/test/java/org/apache/camel/kafkaconnector/PropertiesNameFormatsTest.java
index 5402589..9b39e18 100644
---
a/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesOrderTest.java
+++
b/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesNameFormatsTest.java
@@ -19,12 +19,18 @@ package org.apache.camel.kafkaconnector;
import java.util.HashMap;
import java.util.Map;
+import org.apache.camel.Exchange;
+import org.apache.camel.component.seda.BlockingQueueFactory;
+import org.apache.camel.component.seda.SedaComponent;
+import org.apache.camel.kafkaconnector.test.TestBlockingQueueFactory;
import org.junit.jupiter.api.Test;
-public class PropertiesOrderTest {
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+public class PropertiesNameFormatsTest {
@Test
- public void testOneOrder() {
+ public void testCamelCaseFormat() {
Map<String, String> props = new HashMap<>();
props.put("camel.source.url", "seda://test");
props.put("camel.source.kafka.topic", "mytopic");
@@ -33,19 +39,26 @@ public class PropertiesOrderTest {
CamelSourceTask camelsourceTask = new CamelSourceTask();
camelsourceTask.start(props);
+ BlockingQueueFactory<Exchange> sedaTestQueue = ((SedaComponent)
camelsourceTask.getCms().getEndpoint("seda://test").getCamelContext().getComponent("seda")).getDefaultQueueFactory();
+
assertEquals("org.apache.camel.kafkaconnector.test.TestBlockingQueueFactory",
sedaTestQueue.getClass().getName());
+ assertEquals(1,
((TestBlockingQueueFactory)sedaTestQueue).getCounter());
camelsourceTask.stop();
}
@Test
- public void testOppositOrder() {
+ public void testDashSeparatedFormat() {
Map<String, String> props = new HashMap<>();
props.put("camel.source.url", "seda://test");
props.put("camel.source.kafka.topic", "mytopic");
- props.put("camel.component.seda.defaultQueueFactory.counter", "1");
- props.put("camel.component.seda.defaultQueueFactory",
"#class:org.apache.camel.kafkaconnector.test.TestBlockingQueueFactory");
+ props.put("camel.component.seda.default-queue-factory",
"#class:org.apache.camel.kafkaconnector.test.TestBlockingQueueFactory");
+ props.put("camel.component.seda.default-queue-factory.counter", "1");
CamelSourceTask camelsourceTask = new CamelSourceTask();
camelsourceTask.start(props);
+ BlockingQueueFactory<Exchange> sedaTestQueue = ((SedaComponent)
camelsourceTask.getCms().getEndpoint("seda://test").getCamelContext().getComponent("seda")).getDefaultQueueFactory();
+
assertEquals("org.apache.camel.kafkaconnector.test.TestBlockingQueueFactory",
sedaTestQueue.getClass().getName());
+ assertEquals(1,
((TestBlockingQueueFactory)sedaTestQueue).getCounter());
camelsourceTask.stop();
}
}
+
diff --git
a/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesOrderTest.java
b/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesOrderTest.java
index 5402589..4d58be8 100644
---
a/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesOrderTest.java
+++
b/core/src/test/java/org/apache/camel/kafkaconnector/PropertiesOrderTest.java
@@ -37,7 +37,7 @@ public class PropertiesOrderTest {
}
@Test
- public void testOppositOrder() {
+ public void testOppositeOrder() {
Map<String, String> props = new HashMap<>();
props.put("camel.source.url", "seda://test");
props.put("camel.source.kafka.topic", "mytopic");
@@ -49,3 +49,4 @@ public class PropertiesOrderTest {
camelsourceTask.stop();
}
}
+
