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
commit ed4603f1a953316f8c4a514a93004f7af23791af Author: Aurélien Pupier <[email protected]> AuthorDate: Mon Oct 12 15:03:30 2020 +0200 Provide API to remove connector in Catalog #573 Signed-off-by: Aurélien Pupier <[email protected]> --- .../catalog/CamelKafkaConnectorCatalog.java | 8 ++++++++ .../catalog/CamelKafkaConnectorCatalogTest.java | 24 ++++++++++++++++++++++ 2 files changed, 32 insertions(+) diff --git a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java index 65d910f..dd6a867 100644 --- a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java +++ b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java @@ -149,4 +149,12 @@ public class CamelKafkaConnectorCatalog { connectorsName.add(connectorName); connectorsModel.put(connectorName, createModel(connectorDefinitionAsJson)); } + + /** + * @param connectorName The connector name to remove from the Catalog + */ + public void removeConnector(String connectorName) { + connectorsName.remove(connectorName); + connectorsModel.remove(connectorName); + } } 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 446bc38..98fad46 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 @@ -84,5 +84,29 @@ class CamelKafkaConnectorCatalogTest { assertEquals("MEDIUM", camelKafkaConnectorOptionModel.getPriority()); assertEquals("A demo description of the component", camelKafkaConnectorOptionModel.getDescription()); } + + @Test + void testRemoveConnector() throws Exception { + String connectorName = "my-test-to-remove-connector"; + catalog.addConnector(connectorName, "{\n" + + " \"connector\": {\n" + + " \"class\": \"org.apache.camel.kafkaconnector.my-test-connector.TestDemoConnector\",\n" + + " \"artifactId\": \"camel-my-test-connector-kafka-connector\",\n" + + " \"groupId\": \"org.apache.camel.kafkaconnector\",\n" + + " \"id\": \"my-test-to-remove-connector\",\n" + + " \"type\": \"sink\",\n" + + " \"version\": \"0.6.0-SNAPSHOT\"\n" + + " },\n" + + " \"properties\": {}\n" + + "}\n"); + + assertTrue(catalog.getConnectorsName().contains(connectorName)); + assertNotNull(catalog.getConnectorsModel().get(connectorName)); + + catalog.removeConnector(connectorName); + + assertFalse(catalog.getConnectorsName().contains(connectorName)); + assertNull(catalog.getConnectorsModel().get(connectorName)); + } }
