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/01/12 09:12:05 UTC
[camel] 03/03: Remove deprecated stuff in platform
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
commit 28e7cc87beb91bddae6b567ea01d4ed3e4fc417c
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Sat Jan 12 10:09:12 2019 +0100
Remove deprecated stuff in platform
---
platforms/camel-catalog-nexus/pom.xml | 146 ---------
platforms/camel-catalog-nexus/readme.md | 24 --
.../camel/catalog/nexus/BaseNexusRepository.java | 277 ----------------
.../nexus/ComponentCatalogNexusRepository.java | 119 -------
.../nexus/ConnectorCatalogNexusRepository.java | 168 ----------
.../camel/catalog/nexus/NexusArtifactDto.java | 111 -------
.../src/main/resources/META-INF/LICENSE.txt | 203 ------------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../LocalFileComponentCatalogNexusRepository.java | 57 ----
.../nexus/LocalFileConnectorNexusRepository.java | 58 ----
.../LocalNexusComponentCatalogRepositoryTest.java | 54 ----
.../nexus/LocalNexusConnectorRepositoryTest.java | 55 ----
.../src/test/resources/log4j2.properties | 28 --
.../resources/nexus-sample-component-result.xml | 40 ---
.../resources/nexus-sample-connector-result.xml | 40 ---
platforms/camel-catalog-rest-app/ReadMe.md | 12 -
platforms/camel-catalog-rest-app/pom.xml | 121 -------
.../camel/catalog/rest/CamelCatalogRestMain.java | 103 ------
.../src/main/resources/META-INF/LICENSE.txt | 203 ------------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../src/main/resources/log4j2.properties | 28 --
platforms/camel-catalog-rest/pom.xml | 223 -------------
.../src/main/docs/camel-catalog-rest.adoc | 45 ---
.../camel/catalog/rest/CamelCatalogRest.java | 351 ---------------------
.../catalog/rest/CamelConnectorCatalogRest.java | 166 ----------
.../src/main/resources/META-INF/LICENSE.txt | 203 ------------
.../src/main/resources/META-INF/NOTICE.txt | 11 -
.../camel/catalog/rest/CamelCatalogRestTest.java | 85 -----
.../catalog/rest/CamelCatalogSwaggerTest.java | 87 -----
.../rest/CamelConnectorCatalogRestTest.java | 89 ------
.../src/test/resources/log4j2.properties | 28 --
platforms/myfoo-connector/pom.xml | 140 --------
.../java/org/myfoo/connector/MyFooComponent.java | 27 --
.../services/org/apache/camel/component/my-foo | 18 --
.../src/main/resources/camel-connector-schema.json | 62 ----
.../src/main/resources/camel-connector.json | 21 --
platforms/pom.xml | 7 +-
37 files changed, 1 insertion(+), 3431 deletions(-)
diff --git a/platforms/camel-catalog-nexus/pom.xml b/platforms/camel-catalog-nexus/pom.xml
deleted file mode 100644
index b7b443e..0000000
--- a/platforms/camel-catalog-nexus/pom.xml
+++ /dev/null
@@ -1,146 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
-
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>platforms</artifactId>
- <version>3.0.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-catalog-nexus</artifactId>
- <packaging>jar</packaging>
- <name>Camel :: Platforms :: Camel Catalog :: Nexus (deprecated)</name>
- <description>Camel Catalog Nexus</description>
-
- <properties>
- <!-- use by camel-catalog -->
- <firstVersion>2.19.0</firstVersion>
- <label>tooling</label>
-
- <camel.osgi.export.pkg>
- org.apache.camel.catalog.nexus
- </camel.osgi.export.pkg>
- </properties>
-
- <dependencies>
-
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog-connector</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog-maven</artifactId>
- </dependency>
-
- <!-- testing -->
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog-provider-springboot</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-api</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-core</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- <scope>test</scope>
- </dependency>
-
- </dependencies>
-
- <build>
- <defaultGoal>install</defaultGoal>
-
- <resources>
- <resource>
- <targetPath>${project.build.directory}/test-classes</targetPath>
- <directory>src/test/resources</directory>
- <includes>
- <include>*.xml</include>
- </includes>
- <filtering>true</filtering>
- </resource>
- </resources>
-
- <plugins>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-resources-plugin</artifactId>
- <version>${maven-resources-plugin-version}</version>
- <executions>
- <execution>
- <id>copy-dummy-component</id>
- <phase>process-resources</phase>
- <goals>
- <goal>copy-resources</goal>
- </goals>
- <configuration>
- <outputDirectory>${project.build.directory}/localrepo</outputDirectory>
- <resources>
- <resource>
- <directory>../dummy-component/target</directory>
- <includes>
- <include>*.jar</include>
- </includes>
- </resource>
- <resource>
- <directory>../myfoo-connector/target</directory>
- <includes>
- <include>*.jar</include>
- </includes>
- </resource>
- </resources>
- </configuration>
- </execution>
- </executions>
- </plugin>
-
- <plugin>
- <groupId>org.apache.felix</groupId>
- <artifactId>maven-bundle-plugin</artifactId>
- <extensions>true</extensions>
- </plugin>
- </plugins>
-
- </build>
-
-</project>
diff --git a/platforms/camel-catalog-nexus/readme.md b/platforms/camel-catalog-nexus/readme.md
deleted file mode 100644
index 283fb08cbf..0000000
--- a/platforms/camel-catalog-nexus/readme.md
+++ /dev/null
@@ -1,24 +0,0 @@
-## catalog-nexus
-
-The catalog-nexus is an extension to the Camel Catalog which can be used
-to index a Nexus Maven repository and discover new Camel Components and
-add them to the CamelCatalog.
-
-For example to index an in-house nexus repository and allow developers to
-discover what Camel components is available.
-
-The Camel Catalog can then be used by tooling to present the list of components to developers.
-
-### Nexus
-
-The Nexus repository must provide a REST API which allows this module to query it.
-
-The url is configured on `ComponentCatalogNexusRepository` in the `nexusUrl` setter.
-
-For example if you have a nexus repository at: `http://company-nexus` then the url can be set as
-
- http://company-nexus/service/local/data_index
-
-The nexus repository is periodically scanner (once per minute by default).
-
-
diff --git a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/BaseNexusRepository.java b/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/BaseNexusRepository.java
deleted file mode 100644
index 38bdd6f..0000000
--- a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/BaseNexusRepository.java
+++ /dev/null
@@ -1,277 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.io.Closeable;
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.util.LinkedHashSet;
-import java.util.Set;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-import javax.xml.XMLConstants;
-import javax.xml.parsers.DocumentBuilder;
-import javax.xml.parsers.DocumentBuilderFactory;
-import javax.xml.xpath.XPath;
-import javax.xml.xpath.XPathConstants;
-import javax.xml.xpath.XPathFactory;
-
-import org.w3c.dom.Document;
-import org.w3c.dom.Node;
-import org.w3c.dom.NodeList;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * A base class for scanning and index Maven Nexus repositories for artifacts which can be added to catalogs.
- */
-public abstract class BaseNexusRepository {
-
- final Logger logger = LoggerFactory.getLogger(getClass());
- boolean log;
-
- private final Set<NexusArtifactDto> indexedArtifacts = new LinkedHashSet<>();
-
- private volatile ScheduledExecutorService executorService;
- private AtomicBoolean started = new AtomicBoolean();
-
- private int initialDelay = 10;
- private int delay = 60;
- private String nexusUrl = "http://nexus/service/local/data_index";
- private String classifier;
-
- public BaseNexusRepository(String classifier) {
- this.classifier = classifier;
- }
-
- /**
- * Sets whether to log errors and warnings to System.out.
- * By default nothing is logged.
- */
- public void setLog(boolean log) {
- this.log = log;
- }
-
- public String getNexusUrl() {
- return nexusUrl;
- }
-
- /**
- * The URL to the Nexus repository to query. The syntax should be <tt>http://nexus/service/local/data_index</tt>, where
- * nexus is the hostname.
- */
- public void setNexusUrl(String nexusUrl) {
- this.nexusUrl = nexusUrl;
- }
-
- public int getInitialDelay() {
- return initialDelay;
- }
-
- /**
- * Delay in seconds before the initial (first) scan.
- */
- public void setInitialDelay(int initialDelay) {
- this.initialDelay = initialDelay;
- }
-
- public int getDelay() {
- return delay;
- }
-
- /**
- * Delay in seconds between scanning.
- */
- public void setDelay(int delay) {
- this.delay = delay;
- }
-
- public String getClassifier() {
- return classifier;
- }
-
- /**
- * Classifier to index. Should be either <tt>component</tt>, or <tt>connector</tt>
- */
- public void setClassifier(String classifier) {
- this.classifier = classifier;
- }
-
- /**
- * Starts the Nexus indexer.
- */
- public void start() {
- if (nexusUrl == null || nexusUrl.isEmpty()) {
- logger.warn("Nexus service not found. Indexing Nexus is not enabled!");
- return;
- }
-
- if (!started.compareAndSet(false, true)) {
- logger.info("NexusRepository is already started");
- return;
- }
-
- logger.info("Starting NexusRepository to scan every {} seconds", delay);
-
- executorService = Executors.newScheduledThreadPool(1);
-
- executorService.scheduleWithFixedDelay(() -> {
- try {
- logger.debug("Indexing Nexus {} +++ start +++", nexusUrl);
- indexNexus();
- } catch (Throwable e) {
- if (e.getMessage().contains("UnknownHostException")) {
- // less noise if its unknown host
- logger.warn("Error indexing Nexus " + nexusUrl + " due unknown hosts: " + e.getMessage());
- } else {
- logger.warn("Error indexing Nexus " + nexusUrl + " due " + e.getMessage(), e);
- }
- } finally {
- logger.debug("Indexing Nexus {} +++ end +++", nexusUrl);
- }
- }, initialDelay, delay, TimeUnit.SECONDS);
- }
-
- /**
- * Stops the Nexus indexer.
- */
- public void stop() {
- logger.info("Stopping NexusRepository");
- if (executorService != null) {
- executorService.shutdownNow();
- executorService = null;
- }
- indexedArtifacts.clear();
-
- started.set(false);
- }
-
- /**
- * Callback when new artifacts has been discovered in Nexus
- */
- abstract void onNewArtifacts(Set<NexusArtifactDto> newArtifacts);
-
- protected URL createNexusUrl() throws MalformedURLException {
- String query = nexusUrl + "?q=" + getClassifier();
- return new URL(query);
- }
-
- /**
- * Creates the url to download the artifact.
- *
- * @param dto the artifact
- * @return the url to download
- */
- protected String createArtifactURL(NexusArtifactDto dto) {
- return dto.getArtifactLink();
- }
-
- /**
- * Runs the task to index nexus for new artifacts
- */
- protected void indexNexus() throws Exception {
- // must have q parameter so use component to find all component
-
- DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
- factory.setNamespaceAware(true);
- factory.setIgnoringElementContentWhitespace(true);
- factory.setIgnoringComments(true);
- factory.setFeature(XMLConstants.FEATURE_SECURE_PROCESSING, Boolean.TRUE);
-
- DocumentBuilder documentBuilder = factory.newDocumentBuilder();
-
- URL url = createNexusUrl();
- InputStream is = url.openStream();
- try {
- Document dom = documentBuilder.parse(is);
-
- XPathFactory xpFactory = XPathFactory.newInstance();
- XPath exp = xpFactory.newXPath();
- NodeList list = (NodeList) exp.evaluate("//data/artifact", dom, XPathConstants.NODESET);
-
- Set<NexusArtifactDto> newArtifacts = new LinkedHashSet<>();
- for (int i = 0; i < list.getLength(); i++) {
- Node node = list.item(i);
-
- String g = getNodeText(node.getChildNodes(), "groupId");
- String a = getNodeText(node.getChildNodes(), "artifactId");
- String v = getNodeText(node.getChildNodes(), "version");
- String l = getNodeText(node.getChildNodes(), "artifactLink");
-
- if (g != null & a != null & v != null & l != null) {
- NexusArtifactDto dto = new NexusArtifactDto();
- dto.setGroupId(g);
- dto.setArtifactId(a);
- dto.setVersion(v);
- dto.setArtifactLink(l);
-
- logger.debug("Found: {}:{}:{}", dto.getGroupId(), dto.getArtifactId(), dto.getVersion());
-
- // is it a new artifact
- boolean newArtifact = true;
- for (NexusArtifactDto existing : indexedArtifacts) {
- if (existing.getGroupId().equals(dto.getGroupId())
- && existing.getArtifactId().equals(dto.getArtifactId())
- && existing.getVersion().equals(dto.getVersion())) {
- newArtifact = false;
- break;
- }
- }
- if (newArtifact) {
- newArtifacts.add(dto);
- }
- }
- }
-
- // if there is any new artifacts then process them
- if (!newArtifacts.isEmpty()) {
- onNewArtifacts(newArtifacts);
- }
- } finally {
- close(is);
- }
- }
-
- private static String getNodeText(NodeList list, String name) {
- for (int i = 0; i < list.getLength(); i++) {
- Node child = list.item(i);
- if (name.equals(child.getNodeName())) {
- return child.getTextContent();
- }
- }
- return null;
- }
-
- private static void close(Closeable... closeables) {
- for (Closeable c : closeables) {
- try {
- if (c != null) {
- c.close();
- }
- } catch (IOException e) {
- // ignore
- }
- }
- }
-
-}
diff --git a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ComponentCatalogNexusRepository.java b/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ComponentCatalogNexusRepository.java
deleted file mode 100644
index 7270403..0000000
--- a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ComponentCatalogNexusRepository.java
+++ /dev/null
@@ -1,119 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.io.IOException;
-import java.net.URL;
-import java.net.URLClassLoader;
-import java.util.Properties;
-import java.util.Set;
-
-import org.apache.camel.catalog.CamelCatalog;
-
-import static org.apache.camel.catalog.maven.ComponentArtifactHelper.extractComponentJavaType;
-import static org.apache.camel.catalog.maven.ComponentArtifactHelper.loadComponentJSonSchema;
-import static org.apache.camel.catalog.maven.ComponentArtifactHelper.loadComponentProperties;
-
-/**
- * Nexus repository that can scan for custom Camel components and add to the {@link org.apache.camel.catalog.CamelCatalog}.
- */
-public class ComponentCatalogNexusRepository extends BaseNexusRepository {
-
- private CamelCatalog camelCatalog;
-
- public ComponentCatalogNexusRepository() {
- super("component");
- }
-
- public CamelCatalog getCamelCatalog() {
- return camelCatalog;
- }
-
- /**
- * Sets the {@link CamelCatalog} to be used.
- */
- public void setCamelCatalog(CamelCatalog camelCatalog) {
- this.camelCatalog = camelCatalog;
- }
-
- @Override
- public void start() {
- if (camelCatalog == null) {
- throw new IllegalArgumentException("CamelCatalog must be configured");
- }
-
- super.start();
- }
-
- @Override
- public void onNewArtifacts(Set<NexusArtifactDto> newArtifacts) {
- // now download the new artifact JARs and look inside to find more details
- for (NexusArtifactDto dto : newArtifacts) {
- try {
- logger.debug("Processing new artifact: {}:{}:{}", dto.getGroupId(), dto.getArtifactId(), dto.getVersion());
- String url = createArtifactURL(dto);
- URL jarUrl = new URL(url);
- addCustomCamelComponentsFromArtifact(dto, jarUrl);
- } catch (Throwable e) {
- logger.warn("Error downloading component JAR " + dto.getArtifactLink() + ". This exception is ignored. " + e.getMessage());
- }
- }
- }
-
- /**
- * Adds the component to the {@link CamelCatalog}
- *
- * @param dto the artifact
- * @param camelCatalog the Camel Catalog
- * @param scheme component name
- * @param javaType component java class
- * @param json component json schema
- */
- protected void addComponent(NexusArtifactDto dto, CamelCatalog camelCatalog, String scheme, String javaType, String json) {
- camelCatalog.addComponent(scheme, javaType, json);
- logger.info("Added component: {}:{}:{} to Camel Catalog", dto.getGroupId(), dto.getArtifactId(), dto.getVersion());
- }
-
- /**
- * Adds any discovered third party Camel components from the artifact.
- */
- private void addCustomCamelComponentsFromArtifact(NexusArtifactDto dto, URL jarUrl) {
- try (URLClassLoader classLoader = new URLClassLoader(new URL[]{jarUrl})) {
- // is there any custom Camel components in this library?
- Properties properties = loadComponentProperties(log, classLoader);
- String components = (String) properties.get("components");
- if (components != null) {
- String[] part = components.split("\\s");
- for (String scheme : part) {
- if (!getCamelCatalog().findComponentNames().contains(scheme)) {
- // find the class name
- String javaType = extractComponentJavaType(log, classLoader, scheme);
- if (javaType != null) {
- String json = loadComponentJSonSchema(log, classLoader, scheme);
- if (json != null) {
- addComponent(dto, getCamelCatalog(), scheme, javaType, json);
- }
- }
- }
- }
- }
- } catch (IOException e) {
- logger.warn("Error scanning JAR for custom Camel components", e);
- }
- }
-
-}
diff --git a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java b/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java
deleted file mode 100644
index 4f00641..0000000
--- a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/ConnectorCatalogNexusRepository.java
+++ /dev/null
@@ -1,168 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.URL;
-import java.net.URLClassLoader;
-import java.util.Set;
-import java.util.stream.Collectors;
-import java.util.stream.StreamSupport;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.camel.catalog.connector.CamelConnectorCatalog;
-
-import static org.apache.camel.catalog.CatalogHelper.loadText;
-
-/**
- * Nexus repository that can scan for custom Camel connectors and add to the {@link CamelConnectorCatalog}.
- */
-public class ConnectorCatalogNexusRepository extends BaseNexusRepository {
-
- private CamelConnectorCatalog camelConnectorCatalog;
-
- public ConnectorCatalogNexusRepository() {
- super("connector");
- }
-
- public CamelConnectorCatalog getCamelConnectorCatalog() {
- return camelConnectorCatalog;
- }
-
- /**
- * Sets the {@link CamelConnectorCatalog} to be used.
- */
- public void setCamelConnectorCatalog(CamelConnectorCatalog camelConnectorCatalog) {
- this.camelConnectorCatalog = camelConnectorCatalog;
- }
-
- @Override
- public void start() {
- if (camelConnectorCatalog == null) {
- throw new IllegalArgumentException("CamelConnectorCatalog must be configured");
- }
-
- super.start();
- }
-
- @Override
- public void onNewArtifacts(Set<NexusArtifactDto> newArtifacts) {
- // now download the new artifact JARs and look inside to find more details
- for (NexusArtifactDto dto : newArtifacts) {
- try {
- logger.debug("Processing new artifact: {}:{}:{}", dto.getGroupId(), dto.getArtifactId(), dto.getVersion());
- String url = createArtifactURL(dto);
- URL jarUrl = new URL(url);
- addCustomCamelConnectorFromArtifact(dto, jarUrl);
- } catch (Throwable e) {
- logger.warn("Error downloading connector JAR " + dto.getArtifactLink() + ". This exception is ignored. " + e.getMessage());
- }
- }
- }
-
- /**
- * Adds the connector to the data store
- *
- * @param dto the artifact
- * @param name the name of connector
- * @param scheme the connector scheme
- * @param javaType the connector java type
- * @param description the description of connector
- * @param labels the labels of connector
- * @param connectorJson camel-connector JSon
- * @param connectorSchemaJson camel-connector-schema JSon
- * @param componentSchemaJson camel-component-schema JSon
- */
- protected void addConnector(NexusArtifactDto dto, String name, String scheme, String javaType, String description, String labels,
- String connectorJson, String connectorSchemaJson, String componentSchemaJson) {
-
- String groupId = dto.getGroupId();
- String artifactId = dto.getArtifactId();
- String version = dto.getVersion();
-
- camelConnectorCatalog.addConnector(groupId, artifactId, version, name, scheme, javaType, description, labels, connectorJson, connectorSchemaJson, componentSchemaJson);
- logger.info("Added connector: {}:{}:{}", dto.getGroupId(), dto.getArtifactId(), dto.getVersion());
- }
-
- /**
- * Adds any discovered third party Camel connectors from the artifact.
- */
- private void addCustomCamelConnectorFromArtifact(NexusArtifactDto dto, URL jarUrl) {
- try (URLClassLoader classLoader = new URLClassLoader(new URL[] {jarUrl});) {
- String[] json = loadConnectorJSonSchema(classLoader);
- if (json != null) {
-
- ObjectMapper mapper = new ObjectMapper();
- JsonNode tree = mapper.readTree(json[0]);
- String name = tree.get("name").textValue();
- String scheme = tree.get("scheme").textValue();
- String javaType = tree.get("javaType").textValue();
- String description = tree.get("description").textValue();
-
- String csb = StreamSupport.stream(tree.withArray("labels").spliterator(), false)
- .map(JsonNode::textValue)
- .collect(Collectors.joining(","));
-
- addConnector(dto, name, scheme, javaType, description, csb, json[0], json[1], json[2]);
- }
- } catch (IOException e) {
- logger.warn("Error scanning JAR for custom Camel connectors", e);
- }
- }
-
- private String[] loadConnectorJSonSchema(ClassLoader classLoader) {
- String[] answer = new String[3];
-
- String path = "camel-connector.json";
- try {
- InputStream is = classLoader.getResourceAsStream(path);
- if (is != null) {
- answer[0] = loadText(is);
- }
- } catch (Throwable e) {
- logger.warn("Error loading " + path + " file", e);
- return null;
- }
-
- path = "camel-connector-schema.json";
- try {
- InputStream is = classLoader.getResourceAsStream(path);
- if (is != null) {
- answer[1] = loadText(is);
- }
- } catch (Throwable e) {
- logger.warn("Error loading " + path + " file", e);
- return null;
- }
-
- path = "camel-component-schema.json";
- try {
- InputStream is = classLoader.getResourceAsStream(path);
- if (is != null) {
- answer[2] = loadText(is);
- }
- } catch (Throwable e) {
- logger.warn("Error loading " + path + " file", e);
- return null;
- }
-
- return answer;
- }
-
-}
diff --git a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/NexusArtifactDto.java b/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/NexusArtifactDto.java
deleted file mode 100644
index 5a65765..0000000
--- a/platforms/camel-catalog-nexus/src/main/java/org/apache/camel/catalog/nexus/NexusArtifactDto.java
+++ /dev/null
@@ -1,111 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.io.Serializable;
-
-/**
- * Represents a Maven artifact from the Nexus repository.
- */
-public class NexusArtifactDto implements Serializable {
-
- private String groupId;
- private String artifactId;
- private String version;
- private String artifactLink;
-
- public NexusArtifactDto() {
- }
-
- public NexusArtifactDto(String groupId, String artifactId, String version, String artifactLink) {
- this.groupId = groupId;
- this.artifactId = artifactId;
- this.version = version;
- this.artifactLink = artifactLink;
- }
-
- public String getGroupId() {
- return groupId;
- }
-
- public void setGroupId(String groupId) {
- this.groupId = groupId;
- }
-
- public String getArtifactId() {
- return artifactId;
- }
-
- public void setArtifactId(String artifactId) {
- this.artifactId = artifactId;
- }
-
- public String getVersion() {
- return version;
- }
-
- public void setVersion(String version) {
- this.version = version;
- }
-
- public String getArtifactLink() {
- return artifactLink;
- }
-
- public void setArtifactLink(String artifactLink) {
- this.artifactLink = artifactLink;
- }
-
- @Override
- public boolean equals(Object o) {
- // use gav for equals/hashCode
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
-
- NexusArtifactDto that = (NexusArtifactDto) o;
-
- if (!groupId.equals(that.groupId)) {
- return false;
- }
- if (!artifactId.equals(that.artifactId)) {
- return false;
- }
- return version.equals(that.version);
- }
-
- @Override
- public int hashCode() {
- int result = groupId.hashCode();
- result = 31 * result + artifactId.hashCode();
- result = 31 * result + version.hashCode();
- return result;
- }
-
- @Override
- public String toString() {
- return "NexusArtifactDto["
- + "groupId='" + groupId + '\''
- + ", artifactId='" + artifactId + '\''
- + ", version='" + version + '\''
- + ", artifactLink='" + artifactLink + '\''
- + ']';
- }
-}
diff --git a/platforms/camel-catalog-nexus/src/main/resources/META-INF/LICENSE.txt b/platforms/camel-catalog-nexus/src/main/resources/META-INF/LICENSE.txt
deleted file mode 100644
index 6b0b127..0000000
--- a/platforms/camel-catalog-nexus/src/main/resources/META-INF/LICENSE.txt
+++ /dev/null
@@ -1,203 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright [yyyy] [name of copyright owner]
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
diff --git a/platforms/camel-catalog-nexus/src/main/resources/META-INF/NOTICE.txt b/platforms/camel-catalog-nexus/src/main/resources/META-INF/NOTICE.txt
deleted file mode 100644
index 2e215bf..0000000
--- a/platforms/camel-catalog-nexus/src/main/resources/META-INF/NOTICE.txt
+++ /dev/null
@@ -1,11 +0,0 @@
- =========================================================================
- == NOTICE file corresponding to the section 4 d of ==
- == the Apache License, Version 2.0, ==
- == in this case for the Apache Camel distribution. ==
- =========================================================================
-
- This product includes software developed by
- The Apache Software Foundation (http://www.apache.org/).
-
- Please read the different LICENSE files present in the licenses directory of
- this distribution.
diff --git a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalFileComponentCatalogNexusRepository.java b/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalFileComponentCatalogNexusRepository.java
deleted file mode 100644
index d9aa9c5..0000000
--- a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalFileComponentCatalogNexusRepository.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.io.File;
-import java.net.MalformedURLException;
-import java.net.URL;
-
-import org.apache.camel.catalog.CamelCatalog;
-
-public class LocalFileComponentCatalogNexusRepository extends ComponentCatalogNexusRepository {
-
- private Runnable onAddComponent;
-
- public Runnable getOnAddComponent() {
- return onAddComponent;
- }
-
- public void setOnAddComponent(Runnable onAddComponent) {
- this.onAddComponent = onAddComponent;
- }
-
- @Override
- protected URL createNexusUrl() throws MalformedURLException {
- File file = new File("target/test-classes/nexus-sample-component-result.xml");
- return new URL("file:" + file.getAbsolutePath());
- }
-
- @Override
- protected String createArtifactURL(NexusArtifactDto dto) {
- // load from local file instead
- return "file:target/localrepo/" + dto.getArtifactId() + "-" + dto.getVersion() + ".jar";
- }
-
- @Override
- protected void addComponent(NexusArtifactDto dto, CamelCatalog camelCatalog, String scheme, String javaType, String json) {
- super.addComponent(dto, camelCatalog, scheme, javaType, json);
-
- if (onAddComponent != null) {
- onAddComponent.run();
- }
- }
-}
diff --git a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalFileConnectorNexusRepository.java b/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalFileConnectorNexusRepository.java
deleted file mode 100644
index 5c4760e..0000000
--- a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalFileConnectorNexusRepository.java
+++ /dev/null
@@ -1,58 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.io.File;
-import java.net.MalformedURLException;
-import java.net.URL;
-
-public class LocalFileConnectorNexusRepository extends ConnectorCatalogNexusRepository {
-
- private Runnable onAddConnector;
-
- public Runnable getOnAddConnector() {
- return onAddConnector;
- }
-
- public void setOnAddConnector(Runnable onAddConnector) {
- this.onAddConnector = onAddConnector;
- }
-
- @Override
- protected URL createNexusUrl() throws MalformedURLException {
- File file = new File("target/test-classes/nexus-sample-connector-result.xml");
- return new URL("file:" + file.getAbsolutePath());
- }
-
- @Override
- protected String createArtifactURL(NexusArtifactDto dto) {
- // load from local file instead
- return "file:target/localrepo/" + dto.getArtifactId() + "-" + dto.getVersion() + ".jar";
- }
-
- @Override
- protected void addConnector(NexusArtifactDto dto, String name, String scheme, String javaType,
- String description, String labels,
- String connectorJson, String connectorSchemaJson, String componentSchemaJson) {
- super.addConnector(dto, name, scheme, javaType, description, labels, connectorJson, connectorSchemaJson, componentSchemaJson);
-
- if (onAddConnector != null) {
- onAddConnector.run();
- }
- }
-
-}
diff --git a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalNexusComponentCatalogRepositoryTest.java b/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalNexusComponentCatalogRepositoryTest.java
deleted file mode 100644
index 24128da..0000000
--- a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalNexusComponentCatalogRepositoryTest.java
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-
-import org.apache.camel.catalog.CamelCatalog;
-import org.apache.camel.catalog.DefaultCamelCatalog;
-import org.junit.Assert;
-import org.junit.Test;
-
-public class LocalNexusComponentCatalogRepositoryTest extends Assert {
-
- private final CamelCatalog catalog = new DefaultCamelCatalog();
-
- @Test
- public void testLocalNexus() throws Exception {
- int before = catalog.findComponentNames().size();
-
- LocalFileComponentCatalogNexusRepository repo = new LocalFileComponentCatalogNexusRepository();
- repo.setCamelCatalog(catalog);
- repo.setInitialDelay(2);
- repo.setDelay(3);
- repo.setNexusUrl("dummy");
-
- final CountDownLatch latch = new CountDownLatch(1);
- repo.setOnAddComponent(latch::countDown);
-
- repo.start();
-
- assertTrue("Should have found component", latch.await(10, TimeUnit.SECONDS));
-
- repo.stop();
-
- int after = catalog.findComponentNames().size();
-
- assertTrue("There should be 1 component found", after - before == 1);
- }
-}
diff --git a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalNexusConnectorRepositoryTest.java b/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalNexusConnectorRepositoryTest.java
deleted file mode 100644
index 0e06dc3..0000000
--- a/platforms/camel-catalog-nexus/src/test/java/org/apache/camel/catalog/nexus/LocalNexusConnectorRepositoryTest.java
+++ /dev/null
@@ -1,55 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.nexus;
-
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-
-import org.apache.camel.catalog.connector.CamelConnectorCatalog;
-import org.apache.camel.catalog.connector.DefaultCamelConnectorCatalog;
-import org.junit.Assert;
-import org.junit.Test;
-
-public class LocalNexusConnectorRepositoryTest extends Assert {
-
- private CamelConnectorCatalog catalog = new DefaultCamelConnectorCatalog();
-
- @Test
- public void testLocalNexus() throws Exception {
- LocalFileConnectorNexusRepository repo = new LocalFileConnectorNexusRepository();
- repo.setInitialDelay(2);
- repo.setDelay(3);
- repo.setNexusUrl("dummy");
- repo.setCamelConnectorCatalog(catalog);
-
- final CountDownLatch latch = new CountDownLatch(1);
- repo.setOnAddConnector(latch::countDown);
-
- int before = catalog.findConnector(false).size();
-
- repo.start();
-
- assertTrue("Should have found connector", latch.await(10, TimeUnit.SECONDS));
-
- repo.stop();
-
- int after = catalog.findConnector(false).size();
-
- assertTrue("There should be 1 connector found", after - before == 1);
- }
-
-}
diff --git a/platforms/camel-catalog-nexus/src/test/resources/log4j2.properties b/platforms/camel-catalog-nexus/src/test/resources/log4j2.properties
deleted file mode 100644
index 29e5c81..0000000
--- a/platforms/camel-catalog-nexus/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-## ---------------------------------------------------------------------------
-## Licensed to the Apache Software Foundation (ASF) under one or more
-## contributor license agreements. See the NOTICE file distributed with
-## this work for additional information regarding copyright ownership.
-## The ASF licenses this file to You under the Apache License, Version 2.0
-## (the "License"); you may not use this file except in compliance with
-## the License. You may obtain a copy of the License at
-##
-## http://www.apache.org/licenses/LICENSE-2.0
-##
-## Unless required by applicable law or agreed to in writing, software
-## distributed under the License is distributed on an "AS IS" BASIS,
-## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-## See the License for the specific language governing permissions and
-## limitations under the License.
-## ---------------------------------------------------------------------------
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-catalog-nexus-test.log
-appender.file.layout.type = PatternLayout
-appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.file.ref = file
diff --git a/platforms/camel-catalog-nexus/src/test/resources/nexus-sample-component-result.xml b/platforms/camel-catalog-nexus/src/test/resources/nexus-sample-component-result.xml
deleted file mode 100644
index 3e1b8cc..0000000
--- a/platforms/camel-catalog-nexus/src/test/resources/nexus-sample-component-result.xml
+++ /dev/null
@@ -1,40 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<search-results>
- <totalCount>1</totalCount>
- <from>-1</from>
- <count>-1</count>
- <tooManyResults>false</tooManyResults>
- <data>
- <artifact>
- <resourceURI>http://nexus.dummy/service/local/repositories/staging/content/org/apache/camel/dummy-component/${project.version}/dummy-component-${project.version}.jar</resourceURI>
- <groupId>org.apache.camel</groupId>
- <artifactId>dummy-component</artifactId>
- <version>${project.version}</version>
- <packaging>jar</packaging>
- <extension>jar</extension>
- <repoId>staging</repoId>
- <contextId>Staging</contextId>
- <pomLink>http://nexus.dummy/service/local/artifact/maven/redirect?r=staging&g=org.apache.camel&a=dummy-component&v=${project.version}&e=pom</pomLink>
- <artifactLink>http://nexus.dummy/service/local/artifact/maven/redirect?r=staging&g=org.apache.camel&a=dummy-component&v=${project.version}&e=jar</artifactLink>
- <highlightedFragment><blockquote>Artifact ID<UL><LI>dummy-<B>component</B></LI></UL></blockquote></highlightedFragment>
- </artifact>
- </data>
-</search-results>
diff --git a/platforms/camel-catalog-nexus/src/test/resources/nexus-sample-connector-result.xml b/platforms/camel-catalog-nexus/src/test/resources/nexus-sample-connector-result.xml
deleted file mode 100644
index fbbcd11..0000000
--- a/platforms/camel-catalog-nexus/src/test/resources/nexus-sample-connector-result.xml
+++ /dev/null
@@ -1,40 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<search-results>
- <totalCount>1</totalCount>
- <from>-1</from>
- <count>-1</count>
- <tooManyResults>false</tooManyResults>
- <data>
- <artifact>
- <resourceURI>http://nexus.dummy/service/local/repositories/staging/content/org/apache/camel/myfoo-connector/${project.version}/myfoo-connector-${project.version}.jar</resourceURI>
- <groupId>org.apache.camel</groupId>
- <artifactId>myfoo-connector</artifactId>
- <version>${project.version}</version>
- <packaging>jar</packaging>
- <extension>jar</extension>
- <repoId>staging</repoId>
- <contextId>Staging</contextId>
- <pomLink>http://nexus.dummy/service/local/artifact/maven/redirect?r=staging&g=org.apache.camel&a=myfoo-connector&v=${project.version}&e=pom</pomLink>
- <artifactLink>http://nexus.dummy/service/local/artifact/maven/redirect?r=staging&g=org.apache.camel&a=myfoo-connector&v=${project.version}&e=jar</artifactLink>
- <highlightedFragment><blockquote>Artifact ID<UL><LI>myfoo-<B>connector</B></LI></UL></blockquote></highlightedFragment>
- </artifact>
- </data>
-</search-results>
diff --git a/platforms/camel-catalog-rest-app/ReadMe.md b/platforms/camel-catalog-rest-app/ReadMe.md
deleted file mode 100644
index 8506593..0000000
--- a/platforms/camel-catalog-rest-app/ReadMe.md
+++ /dev/null
@@ -1,12 +0,0 @@
-Camel Catalog REST Application
-==============================
-
-This is a little standalone application which hosts the Camel Catalog and Connector Catalog REST API.
-
-You can run the application using
-
- mvn compile exec:java
-
-And then from a web browser you can access the REST API from the embedded Swagger UI
-
- http://localhost:8080/api-docs?url=/swagger.json
diff --git a/platforms/camel-catalog-rest-app/pom.xml b/platforms/camel-catalog-rest-app/pom.xml
deleted file mode 100644
index 31d7667..0000000
--- a/platforms/camel-catalog-rest-app/pom.xml
+++ /dev/null
@@ -1,121 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>platforms</artifactId>
- <version>3.0.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-catalog-rest-app</artifactId>
- <packaging>jar</packaging>
- <name>Camel :: Platforms :: Camel Catalog :: REST App (deprecated)</name>
- <description>Camel Catalog REST standalone application</description>
-
- <properties>
- <!-- use by camel-catalog -->
- <firstVersion>2.19.0</firstVersion>
- <label>tooling</label>
- </properties>
-
- <dependencies>
-
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog-rest</artifactId>
- </dependency>
-
- <!-- cxf -->
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-core</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-frontend-jaxrs</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-transports-http</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-transports-http-jetty</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-rs-service-description-swagger</artifactId>
- </dependency>
-
- <!-- to support json -->
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-rs-extension-providers</artifactId>
- </dependency>
- <dependency>
- <groupId>com.fasterxml.jackson.jaxrs</groupId>
- <artifactId>jackson-jaxrs-json-provider</artifactId>
- </dependency>
- <dependency>
- <groupId>com.fasterxml.jackson.core</groupId>
- <artifactId>jackson-databind</artifactId>
- </dependency>
-
- <!-- swagger ui -->
- <dependency>
- <groupId>org.webjars</groupId>
- <artifactId>swagger-ui</artifactId>
- <version>${swagger-ui-version}</version>
- </dependency>
-
- <!-- logging -->
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-api</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-core</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- </dependency>
-
- </dependencies>
-
- <build>
- <plugins>
-
- <!-- to start the application using mvn compile exec:java -->
- <plugin>
- <groupId>org.codehaus.mojo</groupId>
- <artifactId>exec-maven-plugin</artifactId>
- <configuration>
- <mainClass>org.apache.camel.catalog.rest.CamelCatalogRestMain</mainClass>
- </configuration>
- </plugin>
-
- </plugins>
- </build>
-
- </project>
diff --git a/platforms/camel-catalog-rest-app/src/main/java/org/apache/camel/catalog/rest/CamelCatalogRestMain.java b/platforms/camel-catalog-rest-app/src/main/java/org/apache/camel/catalog/rest/CamelCatalogRestMain.java
deleted file mode 100644
index 674a126..0000000
--- a/platforms/camel-catalog-rest-app/src/main/java/org/apache/camel/catalog/rest/CamelCatalogRestMain.java
+++ /dev/null
@@ -1,103 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.rest;
-
-import java.io.Console;
-
-import com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider;
-import org.apache.cxf.endpoint.Server;
-import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
-import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;
-import org.apache.cxf.jaxrs.swagger.Swagger2Feature;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Main to start the Camel Catalog and Connector Catalog REST Api application
- * which runs standalone using an embedded CXF/Jetty server with embedded Swagger Doc and Swagger UI.
- */
-public class CamelCatalogRestMain {
-
- private static final Logger LOGGER = LoggerFactory.getLogger(CamelCatalogRestMain.class);
-
- private Server server;
- private CamelCatalogRest catalog;
- private CamelConnectorCatalogRest connectorCatalog;
- private int port = 8080;
-
- public static void main(String[] args) {
- CamelCatalogRestMain me = new CamelCatalogRestMain();
- me.run();
- }
-
- public void run() {
- LOGGER.info("Starting ...");
-
- catalog = new CamelCatalogRest();
- connectorCatalog = new CamelConnectorCatalogRest();
-
- // setup Apache CXF REST server
- JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean();
- sf.setResourceClasses(CamelCatalogRest.class, CamelConnectorCatalogRest.class);
- sf.setResourceProvider(CamelCatalogRest.class, new SingletonResourceProvider(catalog));
- sf.setResourceProvider(CamelConnectorCatalogRest.class, new SingletonResourceProvider(connectorCatalog));
-
- Swagger2Feature swagger = new Swagger2Feature();
- swagger.setBasePath("/");
- swagger.setScanAllResources(false);
- swagger.setPrettyPrint(true);
- swagger.setSupportSwaggerUi(true);
- swagger.setTitle("Camel Catalog and Connector Catalog REST Api");
- swagger.setDescription("REST Api for the Camel Catalog and Connector Catalog");
- swagger.setVersion(catalog.getCatalogVersion());
- swagger.setContact("Apache Camel");
- sf.getFeatures().add(swagger);
-
- // to use jackson for json
- sf.setProvider(JacksonJsonProvider.class);
- sf.setAddress("http://localhost:" + port);
-
- // create and start the CXF server (non blocking)
- server = sf.create();
- server.start();
-
- LOGGER.info("CamelCatalog REST Api started");
- LOGGER.info("");
- LOGGER.info("\tRest API base path: http://localhost:{}/camel-catalog", port);
- LOGGER.info("\tRest API version: http://localhost:{}/camel-catalog/catalogVersion", port);
- LOGGER.info("");
- LOGGER.info("CamelConnectorCatalog REST Api started");
- LOGGER.info("");
- LOGGER.info("\tRest API base path: http://localhost:{}/camel-connector-catalog", port);
- LOGGER.info("");
- LOGGER.info("\tSwagger Doc: http://localhost:{}/swagger.json", port);
- LOGGER.info("\tSwagger UI: http://localhost:{}/api-docs?url=/swagger.json", port);
- LOGGER.info("");
-
- LOGGER.info("Press Enter to stop");
- Console console = System.console();
- console.readLine();
-
- LOGGER.info("Stopping ...");
-
- server.stop();
- server.destroy();
- LOGGER.info("CamelCatalog REST Api stopped");
- System.exit(0);
- }
-
-}
diff --git a/platforms/camel-catalog-rest-app/src/main/resources/META-INF/LICENSE.txt b/platforms/camel-catalog-rest-app/src/main/resources/META-INF/LICENSE.txt
deleted file mode 100644
index 6b0b127..0000000
--- a/platforms/camel-catalog-rest-app/src/main/resources/META-INF/LICENSE.txt
+++ /dev/null
@@ -1,203 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright [yyyy] [name of copyright owner]
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
diff --git a/platforms/camel-catalog-rest-app/src/main/resources/META-INF/NOTICE.txt b/platforms/camel-catalog-rest-app/src/main/resources/META-INF/NOTICE.txt
deleted file mode 100644
index 2e215bf..0000000
--- a/platforms/camel-catalog-rest-app/src/main/resources/META-INF/NOTICE.txt
+++ /dev/null
@@ -1,11 +0,0 @@
- =========================================================================
- == NOTICE file corresponding to the section 4 d of ==
- == the Apache License, Version 2.0, ==
- == in this case for the Apache Camel distribution. ==
- =========================================================================
-
- This product includes software developed by
- The Apache Software Foundation (http://www.apache.org/).
-
- Please read the different LICENSE files present in the licenses directory of
- this distribution.
diff --git a/platforms/camel-catalog-rest-app/src/main/resources/log4j2.properties b/platforms/camel-catalog-rest-app/src/main/resources/log4j2.properties
deleted file mode 100644
index 0fca4e8..0000000
--- a/platforms/camel-catalog-rest-app/src/main/resources/log4j2.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-## ---------------------------------------------------------------------------
-## Licensed to the Apache Software Foundation (ASF) under one or more
-## contributor license agreements. See the NOTICE file distributed with
-## this work for additional information regarding copyright ownership.
-## The ASF licenses this file to You under the Apache License, Version 2.0
-## (the "License"); you may not use this file except in compliance with
-## the License. You may obtain a copy of the License at
-##
-## http://www.apache.org/licenses/LICENSE-2.0
-##
-## Unless required by applicable law or agreed to in writing, software
-## distributed under the License is distributed on an "AS IS" BASIS,
-## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-## See the License for the specific language governing permissions and
-## limitations under the License.
-## ---------------------------------------------------------------------------
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-catalog-app.log
-appender.file.layout.type = PatternLayout
-appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.out.ref = out
diff --git a/platforms/camel-catalog-rest/pom.xml b/platforms/camel-catalog-rest/pom.xml
deleted file mode 100644
index 1c29afd..0000000
--- a/platforms/camel-catalog-rest/pom.xml
+++ /dev/null
@@ -1,223 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
-
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>platforms</artifactId>
- <version>3.0.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-catalog-rest</artifactId>
- <packaging>jar</packaging>
- <name>Camel :: Platforms :: Camel Catalog :: REST (deprecated)</name>
- <description>Camel Catalog REST</description>
-
- <properties>
- <!-- use by camel-catalog -->
- <firstVersion>2.19.0</firstVersion>
- <label>tooling</label>
- </properties>
-
- <dependencies>
-
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog-connector</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog-maven</artifactId>
- </dependency>
-
- <!-- json parser -->
- <dependency>
- <groupId>com.fasterxml.jackson.core</groupId>
- <artifactId>jackson-databind</artifactId>
- <version>${jackson2-version}</version>
- </dependency>
-
- <!-- REST api -->
- <dependency>
- <groupId>javax.ws.rs</groupId>
- <artifactId>javax.ws.rs-api</artifactId>
- <version>${javax.ws.rs-api-version}</version>
- </dependency>
-
- <!-- swagger annotations -->
- <dependency>
- <groupId>io.swagger</groupId>
- <artifactId>swagger-annotations</artifactId>
- <version>${swagger-java-version}</version>
- </dependency>
-
- <!-- cxf -->
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-core</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-frontend-jaxrs</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-transports-http</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-transports-http-jetty</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-rs-service-description-swagger</artifactId>
- <scope>test</scope>
- </dependency>
-
- <!-- to support json -->
- <dependency>
- <groupId>org.apache.cxf</groupId>
- <artifactId>cxf-rt-rs-extension-providers</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>com.fasterxml.jackson.jaxrs</groupId>
- <artifactId>jackson-jaxrs-json-provider</artifactId>
- <scope>test</scope>
- </dependency>
-
- <!-- testing -->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>junit</groupId>
- <artifactId>junit</artifactId>
- <scope>test</scope>
- </dependency>
-
-
- <!-- swagger ui for testing -->
- <dependency>
- <groupId>org.webjars</groupId>
- <artifactId>swagger-ui</artifactId>
- <version>${swagger-ui-version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.eclipse.jetty</groupId>
- <artifactId>jetty-webapp</artifactId>
- <version>${jetty9-version}</version>
- <scope>test</scope>
- </dependency>
-
- <!-- use rest assured for REST/JSon testing -->
- <dependency>
- <groupId>io.rest-assured</groupId>
- <artifactId>rest-assured</artifactId>
- <version>${rest-assured-version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.hamcrest</groupId>
- <artifactId>hamcrest-core</artifactId>
- <version>1.3</version>
- <scope>test</scope>
- </dependency>
-
- <!-- logging -->
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-api</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-core</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- <scope>test</scope>
- </dependency>
-
- </dependencies>
-
- <profiles>
- <profile>
- <id>java9+</id>
- <activation>
- <jdk>[9,)</jdk>
- </activation>
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <argLine>--patch-module java.xml.ws.annotation=${project.basedir}/target/java9/javax.annotation-api-1.2.jar ${camel.surefire.fork.vmargs}</argLine>
- </configuration>
- </plugin>
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-dependency-plugin</artifactId>
- <version>2.10</version>
- <executions>
- <execution>
- <id>copy</id>
- <phase>validate</phase>
- <goals>
- <goal>copy</goal>
- </goals>
- <configuration>
- <artifactItems>
- <artifactItem>
- <groupId>javax.annotation</groupId>
- <artifactId>javax.annotation-api</artifactId>
- <version>1.2</version>
- <type>jar</type>
- <overWrite>false</overWrite>
- <outputDirectory>${project.basedir}/target/java9</outputDirectory>
- </artifactItem>
- </artifactItems>
- <overWriteReleases>false</overWriteReleases>
- <overWriteSnapshots>true</overWriteSnapshots>
- </configuration>
- </execution>
- </executions>
- </plugin>
- </plugins>
- </build>
- </profile>
- </profiles>
-
- </project>
diff --git a/platforms/camel-catalog-rest/src/main/docs/camel-catalog-rest.adoc b/platforms/camel-catalog-rest/src/main/docs/camel-catalog-rest.adoc
deleted file mode 100644
index 825c06f..0000000
--- a/platforms/camel-catalog-rest/src/main/docs/camel-catalog-rest.adoc
+++ /dev/null
@@ -1,45 +0,0 @@
-= Camel Catalog REST Api
-
-The camel-catalog-rest is a tiny REST API of the Camel Catalog. The API is implemented as a JAX-RS resource class
-with Swagger Annotations to offer Swagger documentation.
-
-== Dependencies
-
-The camel-catalog-rest dependencies has been kept low and neutral so any JAX-RS server can be used to
-host the Camel Catalog REST API.
-
-```
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-catalog</artifactId>
- </dependency>
-
- <!-- REST api -->
- <dependency>
- <groupId>javax.ws.rs</groupId>
- <artifactId>javax.ws.rs-api</artifactId>
- <version>${javax.ws.rs-api-version}</version>
- </dependency>
-
- <!-- swagger annotations -->
- <dependency>
- <groupId>io.swagger</groupId>
- <artifactId>swagger-annotations</artifactId>
- <version>${swagger-java-version}</version>
- </dependency>
-```
-
-== Trying the CamelCatalog REST Api
-
-You can try the rest api by running the `camel-rest-app` application
-
-```
- cd camel-rest-app
- mvn compile exec:java
-```
-
-Then a little standalone application with CXF and embedded Jetty starts up the Camel Catalog REST API service
-which you can access using the urls the application logs to the console.
-
-The application has built in Swagger UI which you can use to try the api.
-
diff --git a/platforms/camel-catalog-rest/src/main/java/org/apache/camel/catalog/rest/CamelCatalogRest.java b/platforms/camel-catalog-rest/src/main/java/org/apache/camel/catalog/rest/CamelCatalogRest.java
deleted file mode 100644
index 9092f6c..0000000
--- a/platforms/camel-catalog-rest/src/main/java/org/apache/camel/catalog/rest/CamelCatalogRest.java
+++ /dev/null
@@ -1,351 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.rest;
-
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import javax.ws.rs.Consumes;
-import javax.ws.rs.GET;
-import javax.ws.rs.POST;
-import javax.ws.rs.Path;
-import javax.ws.rs.PathParam;
-import javax.ws.rs.Produces;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import io.swagger.annotations.ApiParam;
-import org.apache.camel.catalog.CamelCatalog;
-import org.apache.camel.catalog.DefaultCamelCatalog;
-import org.apache.camel.catalog.maven.DefaultMavenArtifactProvider;
-import org.apache.camel.catalog.maven.MavenArtifactProvider;
-
-/**
- * A REST based {@link CamelCatalog} service as a JAX-RS resource class.
- */
-@Api(value = "/camel-catalog", description = "Camel Catalog REST API")
-@Path("/camel-catalog")
-public class CamelCatalogRest {
-
- private CamelCatalog catalog = new DefaultCamelCatalog(true);
- private MavenArtifactProvider maven = new DefaultMavenArtifactProvider();
-
- public CamelCatalog getCatalog() {
- return catalog;
- }
-
- /**
- * To inject an existing {@link CamelCatalog}
- */
- public void setCatalog(CamelCatalog catalog) {
- this.catalog = catalog;
- }
-
- @GET
- @Path("/catalogVersion")
- @Produces("text/plain")
- @ApiOperation(value = "The version of this Camel Catalog")
- public String getCatalogVersion() {
- return catalog.getCatalogVersion();
- }
-
- @GET
- @Path("/findComponentNames")
- @Produces("application/json")
- @ApiOperation(value = "Find all the component names from the Camel catalog")
- public List<String> findComponentNames() {
- return catalog.findComponentNames();
- }
-
- @GET
- @Path("/findDataFormatNames")
- @Produces("application/json")
- @ApiOperation(value = "Find all the data format names from the Camel catalog")
- public List<String> findDataFormatNames() {
- return catalog.findDataFormatNames();
- }
-
- @GET
- @Path("/findLanguageNames")
- @Produces("application/json")
- @ApiOperation(value = "Find all the language names from the Camel catalog")
- public List<String> findLanguageNames() {
- return catalog.findLanguageNames();
- }
-
- @GET
- @Path("/findModelNames")
- @Produces("application/json")
- @ApiOperation(value = "Find all the model (EIP) names from the Camel catalog")
- public List<String> findModelNames() {
- return catalog.findModelNames();
- }
-
- @GET
- @Path("/findComponentNames/{filter}")
- @Produces("application/json")
- @ApiOperation(value = "Find all the component names from the Camel catalog that matches the label")
- public List<String> findComponentNames(@ApiParam("Filter used to only return component names that matches by their labels")
- @PathParam("filter") String filter) {
- return catalog.findComponentNames(filter);
- }
-
- @GET
- @Path("/findDataFormatNames/{filter}")
- @Produces("application/json")
- @ApiOperation(value = "Find all the data format names from the Camel catalog that matches the label")
- public List<String> findDataFormatNames(@ApiParam("Filter used to only return data format names that matches by their labels")
- @PathParam("filter") String filter) {
- return catalog.findDataFormatNames(filter);
- }
-
- @GET
- @Path("/findLanguageNames/{filter}")
- @Produces("application/json")
- @ApiOperation(value = "Find all the language names from the Camel catalog that matches the label")
- public List<String> findLanguageNames(@ApiParam("Filter used to only return language names that matches by their labels")
- @PathParam("filter") String filter) {
- return catalog.findLanguageNames(filter);
- }
-
- @GET
- @Path("/findModelNames/{filter}")
- @Produces("application/json")
- @ApiOperation(value = "Find all the model (EIP) names from the Camel catalog that matches the label")
- public List<String> findModelNames(@ApiParam("Filter used to only return model (EIP) names that matches by their labels")
- @PathParam("filter") String filter) {
- return catalog.findModelNames(filter);
- }
-
- @GET
- @Path("/componentJSonSchema/{name}")
- @Produces("application/json")
- @ApiOperation(value = "Returns the component information as JSon format")
- public String componentJSonSchema(@ApiParam(value = "The name of the component", required = true)
- @PathParam("name") String name) {
- return catalog.componentJSonSchema(name);
- }
-
- @GET
- @Path("/dataFormatJSonSchema/{name}")
- @Produces("application/json")
- @ApiOperation(value = "Returns the data format information as JSon format")
- public String dataFormatJSonSchema(@ApiParam(value = "The name of the data format", required = true)
- @PathParam("name") String name) {
- return catalog.dataFormatJSonSchema(name);
- }
-
- @GET
- @Path("/languageJSonSchema/{name}")
- @Produces("application/json")
- @ApiOperation(value = "Returns the language information as JSon format")
- public String languageJSonSchema(@ApiParam(value = "The name of the language", required = true)
- @PathParam("name") String name) {
- return catalog.languageJSonSchema(name);
- }
-
- @GET
- @Path("/modelJSonSchema/{name}")
- @Produces("application/json")
- @ApiOperation(value = "Returns the model (EIP) information as JSon format")
- public String modelJSonSchema(@ApiParam(value = "The name of the model (EIP)", required = true)
- @PathParam("name") String name) {
- return catalog.modelJSonSchema(name);
- }
-
- @GET
- @Path("/componentAsciiDoc/{name}")
- @Produces("text/plain")
- @ApiOperation(value = "Returns the component documentation as Ascii doc format")
- public String componentAsciiDoc(@ApiParam(value = "The name of the component", required = true)
- @PathParam("name") String name) {
- return catalog.componentAsciiDoc(name);
- }
-
- @GET
- @Path("/dataFormatAsciiDoc/{name}")
- @Produces("text/plain")
- @ApiOperation(value = "Returns the data format documentation as Ascii doc format")
- public String dataFormatAsciiDoc(@ApiParam(value = "The name of the data format", required = true)
- @PathParam("name") String name) {
- return catalog.dataFormatAsciiDoc(name);
- }
-
- @GET
- @Path("/languageAsciiDoc/{name}")
- @Produces("text/plain")
- @ApiOperation(value = "Returns the language documentation as Ascii doc format")
- public String languageAsciiDoc(@ApiParam(value = "The name of the language", required = true)
- @PathParam("name") String name) {
- return catalog.languageAsciiDoc(name);
- }
-
- @GET
- @Path("/findComponentLabels")
- @Produces("application/json")
- @ApiOperation(value = "Find all the unique label names all the components are using")
- public Set<String> findComponentLabels() {
- return catalog.findComponentLabels();
- }
-
- @GET
- @Path("/findDataFormatLabels")
- @Produces("application/json")
- @ApiOperation(value = "Find all the unique label names all the data formats are using")
- public Set<String> findDataFormatLabels() {
- return catalog.findDataFormatLabels();
- }
-
- @GET
- @Path("/findLanguageLabels")
- @Produces("application/json")
- @ApiOperation(value = "Find all the unique label names all the languages are using")
- public Set<String> findLanguageLabels() {
- return catalog.findLanguageLabels();
- }
-
- @GET
- @Path("/findModelLabels")
- @Produces("application/json")
- @ApiOperation(value = "Find all the unique label names all the models (EIP) are using.")
- public Set<String> findModelLabels() {
- return catalog.findModelLabels();
- }
-
- @GET
- @Path("/archetypeCatalogAsXml")
- @Produces("application/xml")
- @ApiOperation(value = "Returns the Apache Camel Maven Archetype catalog in XML format")
- public String archetypeCatalogAsXml() {
- return catalog.archetypeCatalogAsXml();
- }
-
- @GET
- @Path("/springSchemaAsXml")
- @Produces("application/xml")
- @ApiOperation(value = "Returns the Camel Spring XML schema")
- public String springSchemaAsXml() {
- return catalog.springSchemaAsXml();
- }
-
- @GET
- @Path("/blueprintSchemaAsXml")
- @Produces("application/xml")
- @ApiOperation(value = "Returns the Camel Blueprint XML schema")
- public String blueprintSchemaAsXml() {
- return catalog.blueprintSchemaAsXml();
- }
-
- @GET
- @Path("/listComponentsAsJson")
- @Produces("application/json")
- @ApiOperation(value = "Lists all the components summary details in JSon")
- public String listComponentsAsJson() {
- return catalog.listComponentsAsJson();
- }
-
- @GET
- @Path("/listDataFormatsAsJson")
- @Produces("application/json")
- @ApiOperation(value = "Lists all the data formats summary details in JSon")
- public String listDataFormatsAsJson() {
- return catalog.listDataFormatsAsJson();
- }
-
- @GET
- @Path("/listLanguagesAsJson")
- @Produces("application/json")
- @ApiOperation(value = "Lists all the languages summary details in JSon")
- public String listLanguagesAsJson() {
- return catalog.listLanguagesAsJson();
- }
-
- @GET
- @Path("/listModelsAsJson")
- @Produces("application/json")
- @ApiOperation(value = "Lists all the models (EIP) summary details in JSon")
- public String listModelsAsJson() {
- return catalog.listModelsAsJson();
- }
-
- @GET
- @Path("/summaryAsJson")
- @Produces("application/json")
- @ApiOperation(value = "Reports a summary what the catalog contains in JSon")
- public String summaryAsJson() {
- return catalog.summaryAsJson();
- }
-
- @POST
- @Path("/asEndpointUri/{scheme}")
- @Consumes("application/json")
- @Produces("text/plain")
- @ApiOperation(value = "Creates an endpoint uri in Java style configured using the provided options in the JSon body")
- public String asEndpointUri(@ApiParam(value = "The component scheme", readOnly = true) @PathParam("scheme") String scheme,
- @ApiParam(value = "The options as a JSon map with key/value pairs", required = true) String json) {
- try {
- ObjectMapper mapper = new ObjectMapper();
- Map map = mapper.readValue(json, Map.class);
- return catalog.asEndpointUri(scheme, map, true);
- } catch (Exception e) {
- return null;
- }
- }
-
- @POST
- @Path("/asEndpointUriXml/{scheme}")
- @Consumes("application/json")
- @Produces("text/plain")
- @ApiOperation(value = "Creates an endpoint uri in XML style configured using the provided options in the JSon body")
- public String asEndpointUriXml(@ApiParam(value = "The component scheme", readOnly = true) @PathParam("scheme") String scheme,
- @ApiParam(value = "The options as a JSon map with key/value pairs", required = true) String json) {
- try {
- ObjectMapper mapper = new ObjectMapper();
- Map map = mapper.readValue(json, Map.class);
- return catalog.asEndpointUriXml(scheme, map, true);
- } catch (Exception e) {
- return null;
- }
- }
-
- @POST
- @Path("/mavenCacheDirectory/{name}")
- @ApiOperation(value = "Configures the Maven cache directory to use when downloading artifacts")
- public void mavenCacheDirectory(@ApiParam(value = "The name of the cache directory", required = true) @PathParam("name") String name) {
- maven.setCacheDirectory(name);
- }
-
- @POST
- @Path("/addMavenRepository/{name}/{url}")
- @ApiOperation(value = "Adds a third party Maven repository to use for downloading Maven artifacts")
- public void addMavenRepository(@ApiParam(value = "The name of the Maven repository", required = true) @PathParam("name") String name,
- @ApiParam(value = "The URL of the Maven repository", required = true) @PathParam("url") String url) {
- maven.addMavenRepository(name, url);
- }
-
- @POST
- @Path("/addComponentFromMavenArtifact/{groupId}/{artifactId}/{version}")
- @Produces("application/json")
- @ApiOperation(value = "Downloads the Maven artifact and scan for custom Camel components which will be added to the catalog and returns the names of the found components")
- public Set<String> addComponentFromMavenArtifact(@ApiParam(value = "The Maven groupId", required = true) @PathParam("groupId") String groupId,
- @ApiParam(value = "The Maven artifactId", required = true) @PathParam("artifactId") String artifactId,
- @ApiParam(value = "The Maven version", required = true) @PathParam("version") String version) {
- return maven.addArtifactToCatalog(catalog, null, groupId, artifactId, version);
- }
-
-}
diff --git a/platforms/camel-catalog-rest/src/main/java/org/apache/camel/catalog/rest/CamelConnectorCatalogRest.java b/platforms/camel-catalog-rest/src/main/java/org/apache/camel/catalog/rest/CamelConnectorCatalogRest.java
deleted file mode 100644
index 24c8153..0000000
--- a/platforms/camel-catalog-rest/src/main/java/org/apache/camel/catalog/rest/CamelConnectorCatalogRest.java
+++ /dev/null
@@ -1,166 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.rest;
-
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import javax.ws.rs.Consumes;
-import javax.ws.rs.GET;
-import javax.ws.rs.POST;
-import javax.ws.rs.Path;
-import javax.ws.rs.PathParam;
-import javax.ws.rs.Produces;
-import javax.ws.rs.QueryParam;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import io.swagger.annotations.ApiParam;
-import org.apache.camel.catalog.connector.CamelConnectorCatalog;
-import org.apache.camel.catalog.connector.ConnectorDto;
-import org.apache.camel.catalog.connector.DefaultCamelConnectorCatalog;
-import org.apache.camel.catalog.maven.DefaultMavenArtifactProvider;
-import org.apache.camel.catalog.maven.MavenArtifactProvider;
-
-/**
- * A REST based {@link CamelConnectorCatalog} service as a JAX-RS resource class.
- */
-@Api(value = "/camel-connector-catalog", description = "Camel Connector Catalog REST API")
-@Path("/camel-connector-catalog")
-public class CamelConnectorCatalogRest {
-
- private CamelConnectorCatalog catalog = new DefaultCamelConnectorCatalog();
- private MavenArtifactProvider maven = new DefaultMavenArtifactProvider();
-
- public CamelConnectorCatalog getCatalog() {
- return catalog;
- }
-
- /**
- * To inject an existing {@link CamelConnectorCatalog}
- */
- public void setCatalog(CamelConnectorCatalog catalog) {
- this.catalog = catalog;
- }
-
- @GET
- @Path("/findConnector")
- @Produces("application/json")
- @ApiOperation(value = "Find all the connectors from the catalog")
- public List<ConnectorDto> findConnector(@ApiParam(value = "Whether to include latest version only", defaultValue = "true")
- @QueryParam("latestVersionOnly") Boolean latestVersionOnly) {
- boolean latest = latestVersionOnly != null ? latestVersionOnly : true;
- return catalog.findConnector(latest);
- }
-
- @GET
- @Path("/findConnector/{filter}")
- @Produces("application/json")
- @ApiOperation(value = "Find all the connectors from the catalog")
- public List<ConnectorDto> findConnector(@ApiParam("Filter the connector matching by name, description or labels")
- @PathParam("filter") String filter,
- @ApiParam(value = "Whether to include latest version only", defaultValue = "true")
- @QueryParam("latestVersionOnly") Boolean latestVersionOnly) {
- boolean latest = latestVersionOnly != null ? latestVersionOnly : true;
- return catalog.findConnector(latest);
- }
-
- @GET
- @Path("/connectorJSon/{groupId}/{artifactId}/{version}")
- @Produces("application/json")
- @ApiOperation(value = "Returns the camel-connector json file for the given connector with the Maven coordinate")
- public String connectorJSon(@ApiParam(value = "Maven groupdId of the connector", required = true)
- @PathParam("groupId") String groupId,
- @ApiParam(value = "Maven artifactId of the connector", required = true)
- @PathParam("artifactId") String artifactId,
- @ApiParam(value = "Maven version of the connector", required = true)
- @PathParam("version") String version) {
- return catalog.connectorJSon(groupId, artifactId, version);
- }
-
- @GET
- @Path("/connectorSchemaJSon/{groupId}/{artifactId}/{version}")
- @Produces("application/json")
- @ApiOperation(value = "Returns the camel-connector-schema json file for the given connector with the Maven coordinate")
- public String connectorSchemaJSon(@ApiParam(value = "Maven groupdId of the connector", required = true)
- @PathParam("groupId") String groupId,
- @ApiParam(value = "Maven artifactId of the connector", required = true)
- @PathParam("artifactId") String artifactId,
- @ApiParam(value = "Maven version of the connector", required = true)
- @PathParam("version") String version) {
- return catalog.connectorSchemaJSon(groupId, artifactId, version);
- }
-
- @POST
- @Path("/asEndpointUri/{scheme}")
- @Consumes("application/json")
- @Produces("text/plain")
- @ApiOperation(value = "Creates an endpoint uri in Java style configured using the provided options in the JSon body")
- public String asEndpointUri(@ApiParam(value = "The component scheme", readOnly = true) @PathParam("scheme") String scheme,
- @ApiParam(value = "The options as a JSon map with key/value pairs", required = true) String json) {
- try {
- ObjectMapper mapper = new ObjectMapper();
- Map map = mapper.readValue(json, Map.class);
- return catalog.asEndpointUri(scheme, map, true);
- } catch (Exception e) {
- return null;
- }
- }
-
- @POST
- @Path("/asEndpointUriXml/{scheme}")
- @Consumes("application/json")
- @Produces("text/plain")
- @ApiOperation(value = "Creates an endpoint uri in XML style configured using the provided options in the JSon body")
- public String asEndpointUriXml(@ApiParam(value = "The component scheme", readOnly = true) @PathParam("scheme") String scheme,
- @ApiParam(value = "The options as a JSon map with key/value pairs", required = true) String json) {
- try {
- ObjectMapper mapper = new ObjectMapper();
- Map map = mapper.readValue(json, Map.class);
- return catalog.asEndpointUriXml(scheme, map, true);
- } catch (Exception e) {
- return null;
- }
- }
-
- @POST
- @Path("/mavenCacheDirectory/{name}")
- @ApiOperation(value = "Configures the Maven cache directory to use when downloading artifacts")
- public void mavenCacheDirectory(@ApiParam(value = "The name of the cache directory", required = true) @PathParam("name") String name) {
- maven.setCacheDirectory(name);
- }
-
- @POST
- @Path("/addMavenRepository/{name}/{url}")
- @ApiOperation(value = "Adds a third party Maven repository to use for downloading Maven artifacts")
- public void addMavenRepository(@ApiParam(value = "The name of the Maven repository", required = true) @PathParam("name") String name,
- @ApiParam(value = "The URL of the Maven repository", required = true) @PathParam("url") String url) {
- maven.addMavenRepository(name, url);
- }
-
- @POST
- @Path("/addConnectorFromMavenArtifact/{groupId}/{artifactId}/{version}")
- @Produces("application/json")
- @ApiOperation(value = "Downloads the Maven artifact and scan for custom Camel connectors which will be added to the catalog and returns the names of the found connectors")
- public Set<String> addConnectorFromMavenArtifact(@ApiParam(value = "The Maven groupId", required = true) @PathParam("groupId") String groupId,
- @ApiParam(value = "The Maven artifactId", required = true) @PathParam("artifactId") String artifactId,
- @ApiParam(value = "The Maven version", required = true) @PathParam("version") String version) {
- return maven.addArtifactToCatalog(null, catalog, groupId, artifactId, version);
- }
-
-}
diff --git a/platforms/camel-catalog-rest/src/main/resources/META-INF/LICENSE.txt b/platforms/camel-catalog-rest/src/main/resources/META-INF/LICENSE.txt
deleted file mode 100644
index 6b0b127..0000000
--- a/platforms/camel-catalog-rest/src/main/resources/META-INF/LICENSE.txt
+++ /dev/null
@@ -1,203 +0,0 @@
-
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright [yyyy] [name of copyright owner]
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
diff --git a/platforms/camel-catalog-rest/src/main/resources/META-INF/NOTICE.txt b/platforms/camel-catalog-rest/src/main/resources/META-INF/NOTICE.txt
deleted file mode 100644
index 2e215bf..0000000
--- a/platforms/camel-catalog-rest/src/main/resources/META-INF/NOTICE.txt
+++ /dev/null
@@ -1,11 +0,0 @@
- =========================================================================
- == NOTICE file corresponding to the section 4 d of ==
- == the Apache License, Version 2.0, ==
- == in this case for the Apache Camel distribution. ==
- =========================================================================
-
- This product includes software developed by
- The Apache Software Foundation (http://www.apache.org/).
-
- Please read the different LICENSE files present in the licenses directory of
- this distribution.
diff --git a/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelCatalogRestTest.java b/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelCatalogRestTest.java
deleted file mode 100644
index 46f233b..0000000
--- a/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelCatalogRestTest.java
+++ /dev/null
@@ -1,85 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.rest;
-
-import com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider;
-import org.apache.camel.test.AvailablePortFinder;
-import org.apache.cxf.endpoint.Server;
-import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
-import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;
-import org.hamcrest.Matchers;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-import static io.restassured.RestAssured.given;
-import static org.hamcrest.CoreMatchers.hasItems;
-
-public class CamelCatalogRestTest {
-
- private Server server;
- private CamelCatalogRest catalog;
- private int port;
-
- @Before
- public void setup() {
- catalog = new CamelCatalogRest();
-
- port = AvailablePortFinder.getNextAvailable(9000);
-
- // setup Apache CXF REST server
- JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean();
- sf.setResourceClasses(CamelCatalogRest.class);
- sf.setResourceProvider(CamelCatalogRest.class, new SingletonResourceProvider(catalog));
- // to use jackson for json
- sf.setProvider(JacksonJsonProvider.class);
- sf.setAddress("http://localhost:" + port);
-
- // create and start the CXF server (non blocking)
- server = sf.create();
- server.start();
- }
-
- @After
- public void stop() {
- if (server != null) {
- server.stop();
- }
- }
-
- @Test
- public void testFindComponentLabels() throws Exception {
- given().
- baseUri("http://localhost:" + port).
- accept("application/json").
- when().
- get("/camel-catalog/findComponentLabels").
- then().
- body("$", hasItems("bigdata", "messaging"));
- }
-
- @Test
- public void testComponentJSonSchema() throws Exception {
- given().
- baseUri("http://localhost:" + port).
- accept("application/json").
- when().
- get("/camel-catalog/componentJSonSchema/quartz2").
- then().
- body("component.description", Matchers.is("Provides a scheduled delivery of messages using the Quartz 2.x scheduler."));
- }
-}
diff --git a/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelCatalogSwaggerTest.java b/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelCatalogSwaggerTest.java
deleted file mode 100644
index 91ca90e..0000000
--- a/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelCatalogSwaggerTest.java
+++ /dev/null
@@ -1,87 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.rest;
-
-import com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider;
-import org.apache.camel.test.AvailablePortFinder;
-import org.apache.cxf.endpoint.Server;
-import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
-import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;
-import org.apache.cxf.jaxrs.swagger.Swagger2Feature;
-import org.hamcrest.Matchers;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-import static io.restassured.RestAssured.given;
-
-public class CamelCatalogSwaggerTest {
-
- private Server server;
- private CamelCatalogRest catalog;
- private int port;
-
- @Before
- public void setup() {
- catalog = new CamelCatalogRest();
-
- port = AvailablePortFinder.getNextAvailable(9000);
-
- // setup Apache CXF REST server
- JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean();
- sf.setResourceClasses(CamelCatalogRest.class);
- sf.setResourceProvider(CamelCatalogRest.class, new SingletonResourceProvider(catalog));
-
- Swagger2Feature swagger = new Swagger2Feature();
- swagger.setBasePath("/");
- swagger.setScanAllResources(false);
- swagger.setPrettyPrint(true);
- swagger.setSupportSwaggerUi(true);
- swagger.setTitle("Camel Catalog REST Api");
- swagger.setDescription("REST Api for the Camel Catalog");
- swagger.setVersion(catalog.getCatalogVersion());
- swagger.setContact("Apache Camel");
- sf.getFeatures().add(swagger);
-
- // to use jackson for json
- sf.setProvider(JacksonJsonProvider.class);
- sf.setAddress("http://localhost:" + port);
-
- // create and start the CXF server (non blocking)
- server = sf.create();
- server.start();
- }
-
- @After
- public void stop() {
- if (server != null) {
- server.stop();
- }
- }
-
- @Test
- public void testSwagger() throws Exception {
- given().
- baseUri("http://localhost:" + port).
- when().
- get("/swagger.json").
- then().
- body("paths./camel-catalog/catalogVersion.get.summary", Matchers.is("The version of this Camel Catalog"));
-
- // System.out.println("Swagger UI: http://localhost:9000/api-docs?url=/swagger.json");
- }
-}
diff --git a/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelConnectorCatalogRestTest.java b/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelConnectorCatalogRestTest.java
deleted file mode 100644
index a578092..0000000
--- a/platforms/camel-catalog-rest/src/test/java/org/apache/camel/catalog/rest/CamelConnectorCatalogRestTest.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.catalog.rest;
-
-import com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider;
-import org.apache.camel.test.AvailablePortFinder;
-import org.apache.cxf.endpoint.Server;
-import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
-import org.apache.cxf.jaxrs.lifecycle.SingletonResourceProvider;
-import org.hamcrest.Matchers;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-import static io.restassured.RestAssured.given;
-
-public class CamelConnectorCatalogRestTest {
-
- private Server server;
- private CamelConnectorCatalogRest catalog;
- private int port;
-
- @Before
- public void setup() {
- catalog = new CamelConnectorCatalogRest();
-
- port = AvailablePortFinder.getNextAvailable(9000);
-
- // setup Apache CXF REST server
- JAXRSServerFactoryBean sf = new JAXRSServerFactoryBean();
- sf.setResourceClasses(CamelConnectorCatalogRest.class);
- sf.setResourceProvider(CamelConnectorCatalogRest.class, new SingletonResourceProvider(catalog));
- // to use jackson for json
- sf.setProvider(JacksonJsonProvider.class);
- sf.setAddress("http://localhost:" + port);
-
- // create and start the CXF server (non blocking)
- server = sf.create();
- server.start();
- }
-
- @After
- public void stop() {
- if (server != null) {
- server.stop();
- }
- }
-
- @Test
- public void testEmptyFindConnectors() throws Exception {
- given().
- baseUri("http://localhost:" + port).
- accept("application/json").
- when().
- get("/camel-connector-catalog/findConnector?latestVersionOnly=false").
- then().
- body(Matchers.hasToString("[]"));
- }
-
- @Test
- public void testFindConnectors() throws Exception {
- catalog.getCatalog().addConnector("org.apache.camel", "myfoo-connector", "2.19.0", "MyFoo", "my-foo", "org.myfoo.connector.MyFooComponent",
- "Something cool", "foo,timer", null, null, null);
-
- given().
- baseUri("http://localhost:" + port).
- accept("application/json").
- when().
- get("/camel-connector-catalog/findConnector?latestVersionOnly=false").
- then().
- body(Matchers.containsString("MyFoo"));
-
- }
-
-}
diff --git a/platforms/camel-catalog-rest/src/test/resources/log4j2.properties b/platforms/camel-catalog-rest/src/test/resources/log4j2.properties
deleted file mode 100644
index 4f5943e..0000000
--- a/platforms/camel-catalog-rest/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,28 +0,0 @@
-## ---------------------------------------------------------------------------
-## Licensed to the Apache Software Foundation (ASF) under one or more
-## contributor license agreements. See the NOTICE file distributed with
-## this work for additional information regarding copyright ownership.
-## The ASF licenses this file to You under the Apache License, Version 2.0
-## (the "License"); you may not use this file except in compliance with
-## the License. You may obtain a copy of the License at
-##
-## http://www.apache.org/licenses/LICENSE-2.0
-##
-## Unless required by applicable law or agreed to in writing, software
-## distributed under the License is distributed on an "AS IS" BASIS,
-## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-## See the License for the specific language governing permissions and
-## limitations under the License.
-## ---------------------------------------------------------------------------
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-catalog-rest-test.log
-appender.file.layout.type = PatternLayout
-appender.file.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-appender.out.type = Console
-appender.out.name = out
-appender.out.layout.type = PatternLayout
-appender.out.layout.pattern = %d [%-15.15t] %-5p %-30.30c{1} - %m%n
-rootLogger.level = INFO
-rootLogger.appenderRef.file.ref = file
diff --git a/platforms/myfoo-connector/pom.xml b/platforms/myfoo-connector/pom.xml
deleted file mode 100644
index d0a3864..0000000
--- a/platforms/myfoo-connector/pom.xml
+++ /dev/null
@@ -1,140 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
-
- <modelVersion>4.0.0</modelVersion>
-
- <parent>
- <groupId>org.apache.camel</groupId>
- <artifactId>platforms</artifactId>
- <version>3.0.0-SNAPSHOT</version>
- <relativePath>..</relativePath>
- </parent>
-
- <artifactId>myfoo-connector</artifactId>
- <name>Camel :: Platforms :: My Foo Connector (deprecated)</name>
- <description>Camel My Foo Connector</description>
- <packaging>jar</packaging>
-
- <dependencies>
-
- <!-- base component to use for this connector -->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-core</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <!-- camel-connector -->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-connector</artifactId>
- <version>${project.version}</version>
- </dependency>
-
- <!-- support camel documentation -->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>apt</artifactId>
- <version>${project.version}</version>
- </dependency>
-
-
- </dependencies>
-
- <build>
- <defaultGoal>install</defaultGoal>
-
- <plugins>
-
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-compiler-plugin</artifactId>
- <version>${maven-compiler-plugin-version}</version>
- <configuration>
- <source>1.8</source>
- <target>1.8</target>
- </configuration>
- </plugin>
-
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-resources-plugin</artifactId>
- <version>${maven-resources-plugin-version}</version>
- <configuration>
- <encoding>UTF-8</encoding>
- </configuration>
- </plugin>
-
- <!-- generate components meta-data and validate component includes documentation etc -->
- <plugin>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-package-maven-plugin</artifactId>
- <version>${project.version}</version>
- <executions>
- <execution>
- <id>prepare</id>
- <goals>
- <goal>prepare-components</goal>
- </goals>
- <phase>generate-resources</phase>
- </execution>
- <execution>
- <id>validate</id>
- <goals>
- <goal>validate-components</goal>
- </goals>
- <phase>prepare-package</phase>
- </execution>
- </executions>
- </plugin>
-
- <!-- turn off jar plugin as we use connector plugin to jar instead -->
- <plugin>
- <groupId>org.apache.maven.plugins</groupId>
- <artifactId>maven-jar-plugin</artifactId>
- <version>${maven-jar-plugin-version}</version>
- <executions>
- <execution>
- <id>default-jar</id>
- <phase/>
- </execution>
- </executions>
- </plugin>
-
- <!-- connector plugin will build the jar -->
- <plugin>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-connector-maven-plugin</artifactId>
- <version>${project.version}</version>
- <executions>
- <execution>
- <id>connector</id>
- <goals>
- <goal>jar</goal>
- </goals>
- </execution>
- </executions>
- </plugin>
-
- </plugins>
- </build>
-
-</project>
diff --git a/platforms/myfoo-connector/src/main/java/org/myfoo/connector/MyFooComponent.java b/platforms/myfoo-connector/src/main/java/org/myfoo/connector/MyFooComponent.java
deleted file mode 100644
index 1817f9f..0000000
--- a/platforms/myfoo-connector/src/main/java/org/myfoo/connector/MyFooComponent.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.myfoo.connector;
-
-import org.apache.camel.component.connector.DefaultConnectorComponent;
-
-public class MyFooComponent extends DefaultConnectorComponent {
-
- public MyFooComponent() {
- super("myfoo", "org.myfoo.connector.MyFooComponent");
- }
-
-}
\ No newline at end of file
diff --git a/platforms/myfoo-connector/src/main/resources/META-INF/services/org/apache/camel/component/my-foo b/platforms/myfoo-connector/src/main/resources/META-INF/services/org/apache/camel/component/my-foo
deleted file mode 100644
index 6a0b504..0000000
--- a/platforms/myfoo-connector/src/main/resources/META-INF/services/org/apache/camel/component/my-foo
+++ /dev/null
@@ -1,18 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements. See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-#
-
-class=org.myfoo.connector.MyFooComponent
\ No newline at end of file
diff --git a/platforms/myfoo-connector/src/main/resources/camel-connector-schema.json b/platforms/myfoo-connector/src/main/resources/camel-connector-schema.json
deleted file mode 100644
index 64e68a5..0000000
--- a/platforms/myfoo-connector/src/main/resources/camel-connector-schema.json
+++ /dev/null
@@ -1,62 +0,0 @@
-{
- "component":{
- "kind":"component",
- "baseScheme":"timer",
- "scheme":"my-foo",
- "syntax":"my-foo:timerName",
- "title":"MyFoo",
- "description":"Something cool",
- "label":"foo,timer",
- "deprecated":false,
- "async":false,
- "consumerOnly":true,
- "lenientProperties":false,
- "javaType":"org.myfoo.connector.MyFooComponent",
- "groupId":"org.apache.camel",
- "artifactId":"myfoo-connector",
- "version":"3.0.0-SNAPSHOT"
- },
- "componentProperties":{
-
- },
- "properties":{
- "timerName":{
- "kind":"path",
- "displayName":"Timer Name",
- "group":"consumer",
- "required":true,
- "type":"string",
- "javaType":"java.lang.String",
- "deprecated":false,
- "secret":false,
- "description":"The name of the timer"
- },
- "period":{
- "kind":"parameter",
- "displayName":"Period",
- "group":"consumer",
- "required":false,
- "type":"integer",
- "javaType":"long",
- "deprecated":false,
- "secret":false,
- "defaultValue":5000,
- "description":"If greater than 0 generate periodic events every period milliseconds. The default value is 1000. You can also specify time values using units such as 60s (60 seconds) 5m30s (5 minutes and 30 seconds) and 1h (1 hour)."
- },
- "repeatCount":{
- "kind":"parameter",
- "displayName":"Repeat Count",
- "group":"consumer",
- "required":false,
- "type":"integer",
- "javaType":"long",
- "deprecated":false,
- "secret":false,
- "defaultValue":0,
- "description":"Specifies a maximum limit of number of fires. So if you set it to 1 the timer will only fire once. If you set it to 5 it will only fire five times. A value of zero or negative means fire forever."
- }
- },
- "connectorProperties":{
-
- }
-}
\ No newline at end of file
diff --git a/platforms/myfoo-connector/src/main/resources/camel-connector.json b/platforms/myfoo-connector/src/main/resources/camel-connector.json
deleted file mode 100644
index 49f6a05..0000000
--- a/platforms/myfoo-connector/src/main/resources/camel-connector.json
+++ /dev/null
@@ -1,21 +0,0 @@
-{
- "baseScheme" : "timer",
- "baseGroupId" : "org.apache.camel",
- "baseArtifactId" : "camel-core",
- "baseVersion" : "3.0.0-SNAPSHOT",
- "baseJavaType" : "org.apache.camel.component.timer.TimerComponent",
- "name" : "MyFoo",
- "scheme" : "my-foo",
- "javaType" : "org.myfoo.connector.MyFooComponent",
- "groupId" : "org.myfoo",
- "artifactId" : "myfoo-connector",
- "version" : "3.0.0-SNAPSHOT",
- "description" : "Something cool",
- "labels" : [ "foo", "timer" ],
- "pattern" : "From",
- "endpointOptions" : [ "timerName", "period", "repeatCount" ],
- "endpointValues" : {
- "fixedRate" : true,
- "period" : 5000
- }
-}
\ No newline at end of file
diff --git a/platforms/pom.xml b/platforms/pom.xml
index 07bb362..6392f8b 100644
--- a/platforms/pom.xml
+++ b/platforms/pom.xml
@@ -37,19 +37,14 @@
<module>commands</module>
<module>karaf</module>
<module>spring-boot</module>
- <!-- dummy/myfoo used for testing catalog -->
+ <!-- dummy used for testing catalog -->
<module>dummy-component</module>
- <module>myfoo-connector</module>
<!-- run camel-catalog last -->
<module>camel-catalog</module>
- <module>camel-catalog-connector</module>
<module>camel-catalog-provider-karaf</module>
<module>camel-catalog-provider-springboot</module>
<module>camel-catalog-lucene</module>
<module>camel-catalog-maven</module>
- <module>camel-catalog-nexus</module>
- <module>camel-catalog-rest</module>
- <module>camel-catalog-rest-app</module>
</modules>
</project>