You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/14 16:37:18 UTC
[camel-kafka-connector] branch master updated:
Camel-kafka-connector-catalog: Adding some more tests
This is an automated email from the ASF dual-hosted git repository.
acosentino 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 55c5556 Camel-kafka-connector-catalog: Adding some more tests
55c5556 is described below
commit 55c5556562b22cd987a44b0c04a5e7d6409cb268
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 17:32:31 2020 +0200
Camel-kafka-connector-catalog: Adding some more tests
---
.../catalog/CamelKafkaConnectorCatalogTest.java | 35 +++++++++++++++++++++-
1 file changed, 34 insertions(+), 1 deletion(-)
diff --git a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
index 2c146c4..e2aa41c 100644
--- a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
+++ b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
@@ -47,7 +47,7 @@ class CamelKafkaConnectorCatalogTest {
}
@Test
- void testOptions() throws Exception {
+ void testAws2S3Options() throws Exception {
Map<String, CamelKafkaConnectorModel> p = catalog.getConnectorsModel();
CamelKafkaConnectorModel model = p.get("camel-aws2-s3-sink");
assertEquals("org.apache.camel.kafkaconnector", model.getGroupId());
@@ -61,6 +61,39 @@ class CamelKafkaConnectorCatalogTest {
assertEquals(model.getTransforms().size(), 1);
assertNull(model.getAggregationStrategies());
}
+
+ @Test
+ void testAws2SnsOptions() throws Exception {
+ Map<String, CamelKafkaConnectorModel> p = catalog.getConnectorsModel();
+ CamelKafkaConnectorModel model = p.get("camel-aws2-sns-sink");
+ assertEquals("org.apache.camel.kafkaconnector", model.getGroupId());
+ assertEquals("sink", model.getType());
+ assertEquals("org.apache.camel.kafkaconnector.aws2sns.CamelAws2snsSinkConnector", model.getConnectorClass());
+ assertEquals(42, model.getOptions().size());
+ assertEquals("camel.sink.path.topicNameOrArn", model.getOptions().get(0).getName());
+ assertEquals("camel.sink.endpoint.amazonSNSClient", model.getOptions().get(1).getName());
+ assertEquals("camel.sink.endpoint.autoCreateTopic", model.getOptions().get(2).getName());
+ assertEquals("true", model.getOptions().get(2).getDefaultValue());
+ assertNull(model.getOptions().get(1).getDefaultValue());
+ assertNull(model.getConverters());
+ assertNull(model.getTransforms());
+ assertNull(model.getAggregationStrategies());
+ }
+
+ @Test
+ void testCouchbaseOptions() throws Exception {
+ Map<String, CamelKafkaConnectorModel> p = catalog.getConnectorsModel();
+ CamelKafkaConnectorModel model = p.get("camel-couchbase-source");
+ assertEquals("org.apache.camel.kafkaconnector", model.getGroupId());
+ assertEquals("source", model.getType());
+ assertEquals("org.apache.camel.kafkaconnector.couchbase.CamelCouchbaseSourceConnector", model.getConnectorClass());
+ assertEquals(42, model.getOptions().size());
+ assertEquals("camel.source.path.protocol", model.getOptions().get(0).getName());
+ assertNull(model.getOptions().get(0).getDefaultValue());
+ assertNull(model.getConverters());
+ assertNull(model.getTransforms());
+ assertNull(model.getAggregationStrategies());
+ }
@Test
void testAddConnector() throws Exception {