You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2023/07/31 09:37:06 UTC
[camel] 01/01: CAMEL-19686 - Remove Camel-Atlasmap
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch CAMEL-19686
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4b13fca1e09867fb8b85a18d701c3042b2d60f29
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Jul 31 11:36:13 2023 +0200
CAMEL-19686 - Remove Camel-Atlasmap
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
bom/camel-bom/pom.xml | 5 -
catalog/camel-allcomponents/pom.xml | 5 -
.../org/apache/camel/catalog/components.properties | 1 -
.../apache/camel/catalog/components/atlasmap.json | 45 ---
components/camel-atlasmap/pom.xml | 135 -------
.../atlasmap/AtlasMapComponentConfigurer.java | 67 ----
.../atlasmap/AtlasMapEndpointConfigurer.java | 85 ----
.../atlasmap/AtlasMapEndpointUriFactory.java | 75 ----
.../services/org/apache/camel/component.properties | 7 -
.../services/org/apache/camel/component/atlasmap | 2 -
.../org/apache/camel/configurer/atlasmap-component | 2 -
.../org/apache/camel/configurer/atlasmap-endpoint | 2 -
.../org/apache/camel/urifactory/atlasmap-endpoint | 2 -
.../apache/camel/component/atlasmap/atlasmap.json | 45 ---
.../src/main/docs/atlasmap-component.adoc | 90 -----
.../component/atlasmap/AtlasMapComponent.java | 129 -------
.../component/atlasmap/AtlasMapConstants.java | 40 --
.../camel/component/atlasmap/AtlasMapEndpoint.java | 413 --------------------
.../atlasmap/CamelAtlasPropertyStrategy.java | 92 -----
.../component/atlasmap/AtlasMapEndpointTest.java | 201 ----------
.../atlasmap/AtlasMapExtractMappingsTest.java | 71 ----
.../atlasmap/AtlasMapForceReloadTest.java | 102 -----
.../component/atlasmap/AtlasMapJavaToJsonTest.java | 59 ---
.../camel/component/atlasmap/AtlasMapJsonTest.java | 56 ---
.../component/atlasmap/AtlasMapJsonToJavaTest.java | 50 ---
.../atlasmap/AtlasMapJsonToXmlSchemaTest.java | 67 ----
.../component/atlasmap/AtlasMapMultiDocsTest.java | 190 ---------
.../component/atlasmap/AtlasMapMultiNSTest.java | 71 ----
.../component/atlasmap/AtlasMapSingleDocTest.java | 59 ---
.../camel/component/atlasmap/AtlasMapTest.java | 81 ----
.../atlasmap/AtlasMapXmlToXmlDefaultNsTest.java | 64 ---
.../component/atlasmap/AtlasMapXmlToXmlTest.java | 66 ----
.../atlasmap/CamelAtlasPropertyStrategyTest.java | 90 -----
.../org/apache/camel/component/atlasmap/Pojo.java | 31 --
.../org/apache/camel/component/atlasmap/Util.java | 40 --
.../src/test/resources/adm/atlasmap-mapping-n.adm | Bin 5416 -> 0 bytes
.../src/test/resources/adm/atlasmap-mapping.adm | Bin 5235 -> 0 bytes
.../json-schema-source-to-xml-schema-target.adm | Bin 2237 -> 0 bytes
.../atlasmapping-java-to-json.json | 56 ---
.../atlasmapping-json-to-java.json | 56 ---
.../atlasmapping-json/atlasmapping-multidocs.json | 255 ------------
.../atlasmapping-json/atlasmapping-multins.json | 52 ---
.../atlasmapping-json/atlasmapping-singledoc.json | 65 ----
.../atlasmapping-json/atlasmapping-xml-to-xml.json | 66 ----
.../resources/atlasmapping-json/atlasmapping.json | 95 -----
.../AtlasMapExtractMappingsTest-context.xml | 39 --
.../context/AtlasMapForceReloadTest-context.xml | 39 --
.../context/AtlasMapJavaToJsonTest-context.xml | 34 --
.../resources/context/AtlasMapJsonTest-context.xml | 34 --
.../context/AtlasMapJsonToJavaTest-context.xml | 34 --
.../AtlasMapJsonToXmlSchemaTest-context.xml | 34 --
.../context/AtlasMapMultiDocsTest-context.xml | 49 ---
.../context/AtlasMapMultiNSTest-context.xml | 34 --
.../context/AtlasMapSingleDocTest-context.xml | 34 --
.../resources/context/AtlasMapTest-context.xml | 34 --
.../context/AtlasMapXmlToXmlTest-context.xml | 34 --
.../src/test/resources/json-source.json | 47 ---
.../src/test/resources/log4j2.properties | 28 --
.../src/test/resources/xml-target-schemaset.xml | 98 -----
.../MulticastAggregationStrategyTest.java | 30 +-
components/pom.xml | 1 -
.../docs/modules/eips/pages/content-enricher.adoc | 5 +-
.../docs/modules/eips/pages/messaging-mapper.adoc | 2 -
.../org/apache/camel/main/components.properties | 1 -
.../org/apache/camel/support/ExchangeHelper.java | 1 -
.../modules/ROOT/examples/json/atlasmap.json | 1 -
docs/components/modules/ROOT/nav.adoc | 1 -
.../modules/ROOT/pages/atlasmap-component.adoc | 1 -
.../component/ComponentsBuilderFactory.java | 13 -
.../dsl/AtlasmapComponentBuilderFactory.java | 155 --------
.../src/generated/resources/metadata.json | 22 --
.../builder/endpoint/EndpointBuilderFactory.java | 1 -
.../camel/builder/endpoint/EndpointBuilders.java | 1 -
.../builder/endpoint/StaticEndpointBuilders.java | 55 ---
.../dsl/AtlasMapEndpointBuilderFactory.java | 427 ---------------------
.../camel-component-known-dependencies.properties | 1 -
parent/pom.xml | 6 -
77 files changed, 26 insertions(+), 4455 deletions(-)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 56aa1a00476..24ae2b3f66a 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -86,11 +86,6 @@
<artifactId>camel-asterisk</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-atlasmap</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-atmosphere-websocket</artifactId>
diff --git a/catalog/camel-allcomponents/pom.xml b/catalog/camel-allcomponents/pom.xml
index be709761815..672d680eaaf 100644
--- a/catalog/camel-allcomponents/pom.xml
+++ b/catalog/camel-allcomponents/pom.xml
@@ -82,11 +82,6 @@
<artifactId>camel-asterisk</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-atlasmap</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-atmosphere-websocket</artifactId>
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index df192153050..d7ffb452357 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -3,7 +3,6 @@ amqp
arangodb
as2
asterisk
-atlasmap
atmosphere-websocket
atom
avro
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/atlasmap.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/atlasmap.json
deleted file mode 100644
index 3ddd7138eeb..00000000000
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/atlasmap.json
+++ /dev/null
@@ -1,45 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "atlasmap",
- "title": "AtlasMap",
- "description": "Transforms the message using an AtlasMap transformation.",
- "deprecated": false,
- "firstVersion": "3.7.0",
- "label": "transformation",
- "javaType": "org.apache.camel.component.atlasmap.AtlasMapComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-atlasmap",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "atlasmap",
- "extendsScheme": "",
- "syntax": "atlasmap:resourceUri",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false
- },
- "componentProperties": {
- "lazyStartProducer": { "index": 0, "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail [...]
- "atlasContextFactory": { "index": 1, "kind": "property", "displayName": "Atlas Context Factory", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "io.atlasmap.api.AtlasContextFactory", "deprecated": false, "autowired": false, "secret": false, "description": "To use the AtlasContextFactory otherwise a new engine is created." },
- "autowiredEnabled": { "index": 2, "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching t [...]
- "propertiesFile": { "index": 3, "kind": "property", "displayName": "Properties File", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The URI of the properties file which is used for AtlasContextFactory initialization." }
- },
- "headers": {
- "CamelAtlasResourceUri": { "index": 0, "kind": "header", "displayName": "", "group": "producer", "label": "", "required": false, "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The new resource URI to use.", "constantName": "org.apache.camel.component.atlasmap.AtlasMapConstants#ATLAS_RESOURCE_URI" },
- "CamelAtlasMapping": { "index": 1, "kind": "header", "displayName": "", "group": "producer", "label": "", "required": false, "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The Atlas mapping to use.", "constantName": "org.apache.camel.component.atlasmap.AtlasMapConstants#ATLAS_MAPPING" },
- "Content-Type": { "index": 2, "kind": "header", "displayName": "", "group": "producer", "label": "", "required": false, "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The content type that is set according to the datasource (json or xml).", "constantName": "org.apache.camel.component.atlasmap.AtlasMapConstants#CONTENT_TYPE" }
- },
- "properties": {
- "resourceUri": { "index": 0, "kind": "path", "displayName": "Resource Uri", "group": "producer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "supportFileReference": true, "description": "Path to the resource. You can prefix with: classpath, file, http, ref, or bean. classpath, file and http loads the resource using these protocols (classpath is default). ref will look [...]
- "allowContextMapAll": { "index": 1, "kind": "parameter", "displayName": "Allow Context Map All", "group": "producer", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether the context map should allow access to all details. By default only the message body and headers can be accessed. This option can be enabled for full access to the current Exchange and C [...]
- "contentCache": { "index": 2, "kind": "parameter", "displayName": "Content Cache", "group": "producer", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether to use resource content cache or not" },
- "forceReload": { "index": 3, "kind": "parameter", "displayName": "Force Reload", "group": "producer", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether to enable or disable force reload mode. This is set to false by default and ADM file is loaded from a file only on a first Exchange, and AtlasContext will be reused after that until endpoint is recreated. If [...]
- "sourceMapName": { "index": 4, "kind": "parameter", "displayName": "Source Map Name", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The Exchange property name for a source message map which hold java.util.Map<String, Message> where the key is AtlasMap Document ID. AtlasMap consumes Message bodies as source documents, as well as message headers as so [...]
- "targetMapMode": { "index": 5, "kind": "parameter", "displayName": "Target Map Mode", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode", "enum": [ "MAP", "MESSAGE_HEADER", "EXCHANGE_PROPERTY" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "MAP", "description": "TargetMapMode enum value to specify how multiple target documents are delivered if exist. 'MAP [...]
- "targetMapName": { "index": 6, "kind": "parameter", "displayName": "Target Map Name", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The Exchange property name for a target document map which hold java.util.Map<String, Object> where the key is AtlasMap Document ID. AtlasMap populates multiple target documents into this map." },
- "lazyStartProducer": { "index": 7, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a produc [...]
- }
-}
diff --git a/components/camel-atlasmap/pom.xml b/components/camel-atlasmap/pom.xml
deleted file mode 100644
index a96ff9fa5c4..00000000000
--- a/components/camel-atlasmap/pom.xml
+++ /dev/null
@@ -1,135 +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>components</artifactId>
- <version>4.0.0-SNAPSHOT</version>
- </parent>
-
- <artifactId>camel-atlasmap</artifactId>
- <packaging>jar</packaging>
- <name>Camel :: AtlasMap</name>
- <description>Camel AtlasMap support</description>
-
- <dependencies>
-
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-support</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-mock</artifactId>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-xml-jaxb</artifactId>
- </dependency>
-
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-api</artifactId>
- <version>${atlasmap-version}</version>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-core</artifactId>
- <version>${atlasmap-version}</version>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-java-module</artifactId>
- <version>${atlasmap-version}</version>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-json-module</artifactId>
- <version>${atlasmap-version}</version>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-xml-module</artifactId>
- <version>${atlasmap-version}</version>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-csv-module</artifactId>
- <version>${atlasmap-version}</version>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-dfdl-module</artifactId>
- <version>${atlasmap-version}</version>
- <scope>provided</scope>
- </dependency>
-
- <!-- test dependencies -->
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-java-test-model</artifactId>
- <version>${atlasmap-version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-xml-test-model</artifactId>
- <version>${atlasmap-version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-xml-core</artifactId>
- <version>${atlasmap-version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-spring-junit5</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.junit.jupiter</groupId>
- <artifactId>junit-jupiter</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <version>${mockito-version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.twitter4j</groupId>
- <artifactId>twitter4j-core</artifactId>
- <version>${twitter4j-version}</version>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.xmlunit</groupId>
- <artifactId>xmlunit-core</artifactId>
- <version>${xmlunit-version}</version>
- <scope>test</scope>
- </dependency>
- </dependencies>
-
-</project>
diff --git a/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapComponentConfigurer.java b/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapComponentConfigurer.java
deleted file mode 100644
index 146dea053c7..00000000000
--- a/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapComponentConfigurer.java
+++ /dev/null
@@ -1,67 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.atlasmap;
-
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@SuppressWarnings("unchecked")
-public class AtlasMapComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- AtlasMapComponent target = (AtlasMapComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "atlascontextfactory":
- case "atlasContextFactory": target.setAtlasContextFactory(property(camelContext, io.atlasmap.api.AtlasContextFactory.class, value)); return true;
- case "autowiredenabled":
- case "autowiredEnabled": target.setAutowiredEnabled(property(camelContext, boolean.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "propertiesfile":
- case "propertiesFile": target.setPropertiesFile(property(camelContext, java.lang.String.class, value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "atlascontextfactory":
- case "atlasContextFactory": return io.atlasmap.api.AtlasContextFactory.class;
- case "autowiredenabled":
- case "autowiredEnabled": return boolean.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "propertiesfile":
- case "propertiesFile": return java.lang.String.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- AtlasMapComponent target = (AtlasMapComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "atlascontextfactory":
- case "atlasContextFactory": return target.getAtlasContextFactory();
- case "autowiredenabled":
- case "autowiredEnabled": return target.isAutowiredEnabled();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "propertiesfile":
- case "propertiesFile": return target.getPropertiesFile();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapEndpointConfigurer.java b/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapEndpointConfigurer.java
deleted file mode 100644
index d21a4a50e49..00000000000
--- a/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapEndpointConfigurer.java
+++ /dev/null
@@ -1,85 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.atlasmap;
-
-import java.util.Map;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
-import org.apache.camel.spi.PropertyConfigurerGetter;
-import org.apache.camel.spi.ConfigurerStrategy;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
-import org.apache.camel.util.CaseInsensitiveMap;
-import org.apache.camel.support.component.PropertyConfigurerSupport;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@SuppressWarnings("unchecked")
-public class AtlasMapEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- AtlasMapEndpoint target = (AtlasMapEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "allowcontextmapall":
- case "allowContextMapAll": target.setAllowContextMapAll(property(camelContext, boolean.class, value)); return true;
- case "contentcache":
- case "contentCache": target.setContentCache(property(camelContext, boolean.class, value)); return true;
- case "forcereload":
- case "forceReload": target.setForceReload(property(camelContext, boolean.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "sourcemapname":
- case "sourceMapName": target.setSourceMapName(property(camelContext, java.lang.String.class, value)); return true;
- case "targetmapmode":
- case "targetMapMode": target.setTargetMapMode(property(camelContext, org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode.class, value)); return true;
- case "targetmapname":
- case "targetMapName": target.setTargetMapName(property(camelContext, java.lang.String.class, value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "allowcontextmapall":
- case "allowContextMapAll": return boolean.class;
- case "contentcache":
- case "contentCache": return boolean.class;
- case "forcereload":
- case "forceReload": return boolean.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "sourcemapname":
- case "sourceMapName": return java.lang.String.class;
- case "targetmapmode":
- case "targetMapMode": return org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode.class;
- case "targetmapname":
- case "targetMapName": return java.lang.String.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- AtlasMapEndpoint target = (AtlasMapEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "allowcontextmapall":
- case "allowContextMapAll": return target.isAllowContextMapAll();
- case "contentcache":
- case "contentCache": return target.isContentCache();
- case "forcereload":
- case "forceReload": return target.isForceReload();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "sourcemapname":
- case "sourceMapName": return target.getSourceMapName();
- case "targetmapmode":
- case "targetMapMode": return target.getTargetMapMode();
- case "targetmapname":
- case "targetMapName": return target.getTargetMapName();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapEndpointUriFactory.java b/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapEndpointUriFactory.java
deleted file mode 100644
index 54709a98f9a..00000000000
--- a/components/camel-atlasmap/src/generated/java/org/apache/camel/component/atlasmap/AtlasMapEndpointUriFactory.java
+++ /dev/null
@@ -1,75 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.atlasmap;
-
-import java.net.URISyntaxException;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.camel.spi.EndpointUriFactory;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-public class AtlasMapEndpointUriFactory extends org.apache.camel.support.component.EndpointUriFactorySupport implements EndpointUriFactory {
-
- private static final String BASE = ":resourceUri";
-
- private static final Set<String> PROPERTY_NAMES;
- private static final Set<String> SECRET_PROPERTY_NAMES;
- private static final Set<String> MULTI_VALUE_PREFIXES;
- static {
- Set<String> props = new HashSet<>(8);
- props.add("allowContextMapAll");
- props.add("contentCache");
- props.add("forceReload");
- props.add("lazyStartProducer");
- props.add("resourceUri");
- props.add("sourceMapName");
- props.add("targetMapMode");
- props.add("targetMapName");
- PROPERTY_NAMES = Collections.unmodifiableSet(props);
- SECRET_PROPERTY_NAMES = Collections.emptySet();
- MULTI_VALUE_PREFIXES = Collections.emptySet();
- }
-
- @Override
- public boolean isEnabled(String scheme) {
- return "atlasmap".equals(scheme);
- }
-
- @Override
- public String buildUri(String scheme, Map<String, Object> properties, boolean encode) throws URISyntaxException {
- String syntax = scheme + BASE;
- String uri = syntax;
-
- Map<String, Object> copy = new HashMap<>(properties);
-
- uri = buildPathParameter(syntax, uri, "resourceUri", null, true, copy);
- uri = buildQueryParameters(uri, copy, encode);
- return uri;
- }
-
- @Override
- public Set<String> propertyNames() {
- return PROPERTY_NAMES;
- }
-
- @Override
- public Set<String> secretPropertyNames() {
- return SECRET_PROPERTY_NAMES;
- }
-
- @Override
- public Set<String> multiValuePrefixes() {
- return MULTI_VALUE_PREFIXES;
- }
-
- @Override
- public boolean isLenientProperties() {
- return false;
- }
-}
-
diff --git a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/component.properties b/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/component.properties
deleted file mode 100644
index e0bc82c4b7f..00000000000
--- a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/component.properties
+++ /dev/null
@@ -1,7 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-components=atlasmap
-groupId=org.apache.camel
-artifactId=camel-atlasmap
-version=4.0.0-SNAPSHOT
-projectName=Camel :: AtlasMap
-projectDescription=Camel AtlasMap support
diff --git a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/component/atlasmap b/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/component/atlasmap
deleted file mode 100644
index 406d04c5d60..00000000000
--- a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/component/atlasmap
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.atlasmap.AtlasMapComponent
diff --git a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/configurer/atlasmap-component b/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/configurer/atlasmap-component
deleted file mode 100644
index efa1c2abaf9..00000000000
--- a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/configurer/atlasmap-component
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.atlasmap.AtlasMapComponentConfigurer
diff --git a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/configurer/atlasmap-endpoint b/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/configurer/atlasmap-endpoint
deleted file mode 100644
index 453e0717d92..00000000000
--- a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/configurer/atlasmap-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.atlasmap.AtlasMapEndpointConfigurer
diff --git a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/urifactory/atlasmap-endpoint b/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/urifactory/atlasmap-endpoint
deleted file mode 100644
index bbe50462b24..00000000000
--- a/components/camel-atlasmap/src/generated/resources/META-INF/services/org/apache/camel/urifactory/atlasmap-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.atlasmap.AtlasMapEndpointUriFactory
diff --git a/components/camel-atlasmap/src/generated/resources/org/apache/camel/component/atlasmap/atlasmap.json b/components/camel-atlasmap/src/generated/resources/org/apache/camel/component/atlasmap/atlasmap.json
deleted file mode 100644
index 3ddd7138eeb..00000000000
--- a/components/camel-atlasmap/src/generated/resources/org/apache/camel/component/atlasmap/atlasmap.json
+++ /dev/null
@@ -1,45 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "atlasmap",
- "title": "AtlasMap",
- "description": "Transforms the message using an AtlasMap transformation.",
- "deprecated": false,
- "firstVersion": "3.7.0",
- "label": "transformation",
- "javaType": "org.apache.camel.component.atlasmap.AtlasMapComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-atlasmap",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "atlasmap",
- "extendsScheme": "",
- "syntax": "atlasmap:resourceUri",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false
- },
- "componentProperties": {
- "lazyStartProducer": { "index": 0, "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail [...]
- "atlasContextFactory": { "index": 1, "kind": "property", "displayName": "Atlas Context Factory", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "io.atlasmap.api.AtlasContextFactory", "deprecated": false, "autowired": false, "secret": false, "description": "To use the AtlasContextFactory otherwise a new engine is created." },
- "autowiredEnabled": { "index": 2, "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching t [...]
- "propertiesFile": { "index": 3, "kind": "property", "displayName": "Properties File", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The URI of the properties file which is used for AtlasContextFactory initialization." }
- },
- "headers": {
- "CamelAtlasResourceUri": { "index": 0, "kind": "header", "displayName": "", "group": "producer", "label": "", "required": false, "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The new resource URI to use.", "constantName": "org.apache.camel.component.atlasmap.AtlasMapConstants#ATLAS_RESOURCE_URI" },
- "CamelAtlasMapping": { "index": 1, "kind": "header", "displayName": "", "group": "producer", "label": "", "required": false, "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The Atlas mapping to use.", "constantName": "org.apache.camel.component.atlasmap.AtlasMapConstants#ATLAS_MAPPING" },
- "Content-Type": { "index": 2, "kind": "header", "displayName": "", "group": "producer", "label": "", "required": false, "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The content type that is set according to the datasource (json or xml).", "constantName": "org.apache.camel.component.atlasmap.AtlasMapConstants#CONTENT_TYPE" }
- },
- "properties": {
- "resourceUri": { "index": 0, "kind": "path", "displayName": "Resource Uri", "group": "producer", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "supportFileReference": true, "description": "Path to the resource. You can prefix with: classpath, file, http, ref, or bean. classpath, file and http loads the resource using these protocols (classpath is default). ref will look [...]
- "allowContextMapAll": { "index": 1, "kind": "parameter", "displayName": "Allow Context Map All", "group": "producer", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether the context map should allow access to all details. By default only the message body and headers can be accessed. This option can be enabled for full access to the current Exchange and C [...]
- "contentCache": { "index": 2, "kind": "parameter", "displayName": "Content Cache", "group": "producer", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether to use resource content cache or not" },
- "forceReload": { "index": 3, "kind": "parameter", "displayName": "Force Reload", "group": "producer", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether to enable or disable force reload mode. This is set to false by default and ADM file is loaded from a file only on a first Exchange, and AtlasContext will be reused after that until endpoint is recreated. If [...]
- "sourceMapName": { "index": 4, "kind": "parameter", "displayName": "Source Map Name", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The Exchange property name for a source message map which hold java.util.Map<String, Message> where the key is AtlasMap Document ID. AtlasMap consumes Message bodies as source documents, as well as message headers as so [...]
- "targetMapMode": { "index": 5, "kind": "parameter", "displayName": "Target Map Mode", "group": "producer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode", "enum": [ "MAP", "MESSAGE_HEADER", "EXCHANGE_PROPERTY" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "MAP", "description": "TargetMapMode enum value to specify how multiple target documents are delivered if exist. 'MAP [...]
- "targetMapName": { "index": 6, "kind": "parameter", "displayName": "Target Map Name", "group": "producer", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "The Exchange property name for a target document map which hold java.util.Map<String, Object> where the key is AtlasMap Document ID. AtlasMap populates multiple target documents into this map." },
- "lazyStartProducer": { "index": 7, "kind": "parameter", "displayName": "Lazy Start Producer", "group": "producer (advanced)", "label": "producer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a produc [...]
- }
-}
diff --git a/components/camel-atlasmap/src/main/docs/atlasmap-component.adoc b/components/camel-atlasmap/src/main/docs/atlasmap-component.adoc
deleted file mode 100644
index d21ed5e8a9e..00000000000
--- a/components/camel-atlasmap/src/main/docs/atlasmap-component.adoc
+++ /dev/null
@@ -1,90 +0,0 @@
-= AtlasMap Component
-:doctitle: AtlasMap
-:shortname: atlasmap
-:artifactid: camel-atlasmap
-:description: Transforms the message using an AtlasMap transformation.
-:since: 3.7
-:supportlevel: Stable
-:tabs-sync-option:
-:component-header: Only producer is supported
-//Manually maintained attributes
-:camel-spring-boot-name: atlasmap
-
-*Since Camel {since}*
-
-*{component-header}*
-
-The AtlasMap component allows you to process data mapping using an
-http://www.atlasmap.io/[AtlasMap] data mapping definition. The AtlasMap mapping definition
-is packaged as an ADM archive file when it is exported from the AtlasMap Data Mapper UI.
-NOTE: Although it is possible to load mapping definition JSON file without being packaged into ADM archive file, some features will not work in that way. It is recommended to always use ADM archive file for other than developer test purpose.
-
-Maven users will need to add the following dependency to their `pom.xml`
-for this component:
-
-[source,xml]
-------------------------------------------------------------
-<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-atlasmap</artifactId>
- <version>x.x.x</version>
- <!-- use the same version as your Camel core version -->
-</dependency>
-------------------------------------------------------------
-
-Optionally you can include the DFDL module, which is a POC for https://daffodil.apache.org/[Apache Daffodil]:
-[source,xml]
-------------------------------------------------------------
-<dependency>
- <groupId>io.atlasmap</groupId>
- <artifactId>atlas-dfdl-module</artifactId>
- <version>x.x.x</version>
- <!-- use the same version as atlasmap-core in camel-atlasmap -->
-</dependency>
-------------------------------------------------------------
-
-== URI format
-
-[source,java]
----------------------------
-atlasmap:mappingName[?options]
----------------------------
-
-Where *mappingName* is the classpath-local URI of the AtlasMap
-mapping definition, either ADM archive file or mapping definition JSON file
- to process.
-
-// component-configure options: START
-
-// component-configure options: END
-
-// component options: START
-include::partial$component-configure-options.adoc[]
-include::partial$component-endpoint-options.adoc[]
-// component options: END
-
-// endpoint options: START
-
-// endpoint options: END
-
-// component headers: START
-include::partial$component-endpoint-headers.adoc[]
-// component headers: END
-
-== Examples
-
-=== Producer Example
-
-You could use something like
-
-[source,java]
---------------------------------------
-from("activemq:My.Queue").
- to("atlasmap:atlasmap-mapping.adm");
---------------------------------------
-
-where you can export an ADM archive file from AtlasMap Data Mapper UI.
-
-
-
-include::spring-boot:partial$starter.adoc[]
diff --git a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapComponent.java b/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapComponent.java
deleted file mode 100644
index a8a451d36f8..00000000000
--- a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapComponent.java
+++ /dev/null
@@ -1,129 +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.component.atlasmap;
-
-import java.io.InputStream;
-import java.util.Map;
-import java.util.Properties;
-
-import io.atlasmap.api.AtlasContextFactory;
-import io.atlasmap.core.DefaultAtlasContextFactory;
-import org.apache.camel.Endpoint;
-import org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.camel.support.DefaultComponent;
-import org.apache.camel.support.ResourceHelper;
-import org.apache.camel.util.IOHelper;
-import org.apache.camel.util.ObjectHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * The <a href="http://camel.apache.org/atlasmap-component.html">AtlasMap Component</a> is for working with AtlasMap
- * Data Mapper.
- */
-@Component("atlasmap")
-public class AtlasMapComponent extends DefaultComponent {
-
- private static final Logger LOG = LoggerFactory.getLogger(AtlasMapComponent.class);
-
- @Metadata(label = "advanced")
- private AtlasContextFactory atlasContextFactory;
-
- @Metadata(label = "advanced")
- private String propertiesFile;
-
- public AtlasContextFactory getAtlasContextFactory() {
- return atlasContextFactory;
- }
-
- /**
- * To use the {@link AtlasContextFactory} otherwise a new engine is created.
- *
- * @param atlasContextFactory {@link AtlasContextFactory}
- */
- public void setAtlasContextFactory(AtlasContextFactory atlasContextFactory) {
- this.atlasContextFactory = atlasContextFactory;
- }
-
- /**
- * The URI of the properties file which is used for AtlasContextFactory initialization.
- *
- * @param file property file path
- */
- public void setPropertiesFile(String file) {
- propertiesFile = file;
- }
-
- public String getPropertiesFile() {
- return propertiesFile;
- }
-
- protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) throws Exception {
- boolean cache = getAndRemoveParameter(parameters, "contentCache", Boolean.class, Boolean.TRUE);
- String sourceMapName = getAndRemoveParameter(parameters, "sourceMapName", String.class);
- String targetMapName = getAndRemoveParameter(parameters, "targetMapName", String.class);
- TargetMapMode targetMapMode = getAndRemoveParameter(parameters, "targetMapMode", TargetMapMode.class);
- boolean forceReload = getAndRemoveParameter(parameters, "forceAdmReload", Boolean.class, Boolean.FALSE);
- AtlasMapEndpoint endpoint = new AtlasMapEndpoint(uri, this, remaining);
- setProperties(endpoint, parameters);
- endpoint.setContentCache(cache);
- endpoint.setSourceMapName(sourceMapName);
- endpoint.setTargetMapName(targetMapName);
- endpoint.setForceReload(forceReload);
- endpoint.setAtlasContextFactory(getOrCreateAtlasContextFactory());
- if (targetMapMode != null) {
- endpoint.setTargetMapMode(targetMapMode);
- }
-
- // if its a http resource then append any remaining parameters and update the
- // resource uri
- if (ResourceHelper.isHttpUri(remaining)) {
- String remainingAndParameters = ResourceHelper.appendParameters(remaining, parameters);
- endpoint.setResourceUri(remainingAndParameters);
- }
-
- return endpoint;
- }
-
- private synchronized AtlasContextFactory getOrCreateAtlasContextFactory() throws Exception {
- if (atlasContextFactory != null) {
- return atlasContextFactory;
- }
-
- atlasContextFactory = DefaultAtlasContextFactory.getInstance();
- atlasContextFactory.addClassLoader(getCamelContext().getApplicationContextClassLoader());
- // load the properties from property file which may overrides the default ones
- if (ObjectHelper.isNotEmpty(getPropertiesFile())) {
- Properties properties = new Properties();
- InputStream reader = ResourceHelper.resolveMandatoryResourceAsInputStream(getCamelContext(),
- getPropertiesFile());
- try {
- properties.load(reader);
- LOG.info("Loaded the Atlas properties file {}", getPropertiesFile());
- } finally {
- IOHelper.close(reader, getPropertiesFile(), LOG);
- }
- LOG.debug("Initializing AtlasContextFactory with properties {}", properties);
- atlasContextFactory.setProperties(properties);
- }
- return atlasContextFactory;
- }
-
-}
diff --git a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapConstants.java b/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapConstants.java
deleted file mode 100644
index 5537cdb11ec..00000000000
--- a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapConstants.java
+++ /dev/null
@@ -1,40 +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.component.atlasmap;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.spi.Metadata;
-
-/**
- * AtlasMap Constants.
- */
-public final class AtlasMapConstants {
-
- @Metadata(description = "The new resource URI to use.", javaType = "java.lang.String")
- public static final String ATLAS_RESOURCE_URI = "CamelAtlasResourceUri";
- @Metadata(description = "The Atlas mapping to use.", javaType = "java.lang.String")
- public static final String ATLAS_MAPPING = "CamelAtlasMapping";
- public static final String ATLAS_SOURCE_MAP = "CamelAtlasSourceMap";
- public static final String ATLAS_TARGET_MAP = "CamelAtlasTargetMap";
- @Metadata(description = "The content type that is set according to the datasource (json or xml).",
- javaType = "java.lang.String")
- public static final String CONTENT_TYPE = Exchange.CONTENT_TYPE;
-
- private AtlasMapConstants() {
- }
-
-}
diff --git a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapEndpoint.java b/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapEndpoint.java
deleted file mode 100644
index d949dd7410a..00000000000
--- a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/AtlasMapEndpoint.java
+++ /dev/null
@@ -1,413 +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.component.atlasmap;
-
-import java.io.ByteArrayInputStream;
-import java.io.InputStream;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import io.atlasmap.api.AtlasContext;
-import io.atlasmap.api.AtlasContextFactory;
-import io.atlasmap.api.AtlasException;
-import io.atlasmap.api.AtlasSession;
-import io.atlasmap.v2.Audit;
-import io.atlasmap.v2.DataSource;
-import io.atlasmap.v2.DataSourceType;
-import org.apache.camel.Category;
-import org.apache.camel.Exchange;
-import org.apache.camel.ExchangePattern;
-import org.apache.camel.Message;
-import org.apache.camel.component.ResourceEndpoint;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.support.MessageHelper;
-import org.apache.camel.util.ObjectHelper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import static io.atlasmap.api.AtlasContextFactory.Format.ADM;
-import static io.atlasmap.api.AtlasContextFactory.Format.JSON;
-
-/**
- * Transforms the message using an AtlasMap transformation.
- */
-@UriEndpoint(firstVersion = "3.7.0", scheme = "atlasmap", title = "AtlasMap", syntax = "atlasmap:resourceUri",
- producerOnly = true, category = { Category.TRANSFORMATION }, headersClass = AtlasMapConstants.class)
-public class AtlasMapEndpoint extends ResourceEndpoint {
-
- public static final String CONTENT_TYPE_JSON = "application/json";
- public static final String CONTENT_TYPE_XML = "application/xml";
-
- private static final Logger LOG = LoggerFactory.getLogger(AtlasMapEndpoint.class);
- private AtlasContextFactory atlasContextFactory;
- private AtlasContext atlasContext;
-
- @UriParam
- private String sourceMapName;
- @UriParam
- private String targetMapName;
- @UriParam(defaultValue = "MAP")
- private TargetMapMode targetMapMode = TargetMapMode.MAP;
- @UriParam(defaultValue = "false")
- private boolean forceReload;
-
- public enum TargetMapMode {
- MAP,
- MESSAGE_HEADER,
- EXCHANGE_PROPERTY;
- }
-
- public AtlasMapEndpoint(String uri, AtlasMapComponent component, String resourceUri) {
- super(uri, component, resourceUri);
- }
-
- @Override
- public ExchangePattern getExchangePattern() {
- return ExchangePattern.InOut;
- }
-
- @Override
- protected String createEndpointUri() {
- return "atlasmap:" + getResourceUri();
- }
-
- public AtlasContextFactory getAtlasContextFactory() {
- return this.atlasContextFactory;
- }
-
- public void setAtlasContextFactory(AtlasContextFactory atlasContextFactory) {
- this.atlasContextFactory = atlasContextFactory;
- }
-
- public AtlasContext getAtlasContext() {
- return this.atlasContext;
- }
-
- public void setAtlasContext(AtlasContext atlasContext) {
- this.atlasContext = atlasContext;
- }
-
- /**
- * The Exchange property name for a source message map which hold <code>java.util.Map<String, Message></code>
- * where the key is AtlasMap Document ID. AtlasMap consumes Message bodies as source documents, as well as message
- * headers as source properties where the scope equals to Document ID.
- *
- * @param name Exchange property name for source map
- */
- public void setSourceMapName(String name) {
- this.sourceMapName = name;
- }
-
- public String getSourceMapName() {
- return this.sourceMapName;
- }
-
- /**
- * The Exchange property name for a target document map which hold <code>java.util.Map<String, Object></code>
- * where the key is AtlasMap Document ID. AtlasMap populates multiple target documents into this map.
- *
- * @param name Exchange property name for target map
- */
- public void setTargetMapName(String name) {
- this.targetMapName = name;
- }
-
- public String getTargetMapName() {
- return this.targetMapName;
- }
-
- /**
- * {@link TargetMapMode} enum value to specify how multiple target documents are delivered if exist.
- * <ul>
- * <li>'MAP': Stores them into a java.util.Map, and the java.util.Map is set to an exchange" property if
- * 'targetMapName' is specified, otherwise message body.</li>"
- * <li>'MESSAGE_HEADER': Stores them into message headers.</li>"
- * <li>'EXCHANGE_PROPERTY': Stores them into exchange properties.</li>
- * </ul>
- * ")
- *
- * @param mode {@link TargetMapMode}
- */
- public void setTargetMapMode(TargetMapMode mode) {
- this.targetMapMode = mode;
- }
-
- public TargetMapMode getTargetMapMode() {
- return this.targetMapMode;
- }
-
- /**
- * Whether to enable or disable force reload mode. This is set to false by default and ADM file is loaded from a
- * file only on a first Exchange, and AtlasContext will be reused after that until endpoint is recreated. If this is
- * set to true, ADM file will be loaded from a file on every Exchange.
- *
- * @param forceReload true to enable force reload
- */
- public void setForceReload(boolean forceReload) {
- this.forceReload = forceReload;
- }
-
- public boolean isForceReload() {
- return forceReload;
- }
-
- public AtlasMapEndpoint findOrCreateEndpoint(String uri, String newResourceUri) {
- String newUri = uri.replace(getResourceUri(), newResourceUri);
- log.debug("Getting endpoint with URI: {}", newUri);
- return getCamelContext().getEndpoint(newUri, AtlasMapEndpoint.class);
- }
-
- @Override
- protected void onExchange(Exchange exchange) throws Exception {
- Message incomingMessage = exchange.getIn();
- String newResourceUri = incomingMessage.getHeader(AtlasMapConstants.ATLAS_RESOURCE_URI, String.class);
- if (newResourceUri != null) {
- incomingMessage.removeHeader(AtlasMapConstants.ATLAS_RESOURCE_URI);
-
- log.debug("{} set to {} creating new endpoint to handle exchange", AtlasMapConstants.ATLAS_RESOURCE_URI,
- newResourceUri);
- AtlasMapEndpoint newEndpoint = findOrCreateEndpoint(getEndpointUri(), newResourceUri);
- newEndpoint.onExchange(exchange);
- return;
- }
-
- AtlasSession atlasSession = getOrCreateAtlasContext(incomingMessage).createSession();
- populateSourceDocuments(exchange, atlasSession);
- atlasSession.getAtlasContext().process(atlasSession);
-
- List<Audit> errors = new ArrayList<>();
- for (Audit audit : atlasSession.getAudits().getAudit()) {
- switch (audit.getStatus()) {
- case ERROR:
- errors.add(audit);
- break;
- case WARN:
- LOG.warn("{}: Document='{}(ID:{})', path='{}'",
- audit.getMessage(), audit.getDocName(), audit.getDocId(), audit.getPath());
- break;
- default:
- LOG.info("{}: Document='{}(ID:{})', path='{}'",
- audit.getMessage(), audit.getDocName(), audit.getDocId(), audit.getPath());
- }
- }
- if (!errors.isEmpty()) {
- StringBuilder buf = new StringBuilder("Errors: ");
- errors.stream().forEach(a -> buf.append(
- String.format("[%s: Document='%s(ID:%s)', path='%s'], ",
- a.getMessage(), a.getDocName(), a.getDocId(), a.getPath())));
- throw new AtlasException(buf.toString());
- }
-
- populateTargetDocuments(atlasSession, exchange);
- }
-
- private AtlasContext getOrCreateAtlasContext(Message incomingMessage) throws Exception {
- String path = getResourceUri();
- ObjectHelper.notNull(path, "mappingUri");
-
- String content = incomingMessage.getHeader(AtlasMapConstants.ATLAS_MAPPING, String.class);
- if (content != null) {
- // use content from header
- InputStream is = new ByteArrayInputStream(content.getBytes());
- if (log.isDebugEnabled()) {
- log.debug("Atlas mapping content read from header {} for endpoint {}", AtlasMapConstants.ATLAS_MAPPING,
- getEndpointUri());
- }
- // remove the header to avoid it being propagated in the routing
- incomingMessage.removeHeader(AtlasMapConstants.ATLAS_MAPPING);
- return atlasContextFactory.createContext(JSON, is);
- } else if (getAtlasContext() != null && !forceReload) {
- // no mapping specified in header, and found an existing context
- return getAtlasContext();
- }
-
- // No mapping in header, and no existing context or force reload is enabled. Create new one from resourceUri
- if (log.isDebugEnabled()) {
- log.debug("Atlas mapping content read from resourceUri: {} for endpoint {}",
- path, getEndpointUri());
- }
- atlasContext = atlasContextFactory.createContext(
- path.toLowerCase().endsWith("adm") ? ADM : JSON, getResourceAsInputStream());
- return atlasContext;
- }
-
- private void populateSourceDocuments(Exchange exchange, AtlasSession session) {
- if (session.getMapping().getDataSource() == null) {
- return;
- }
-
- Message inMessage = exchange.getIn();
- CamelAtlasPropertyStrategy propertyStrategy = new CamelAtlasPropertyStrategy();
- propertyStrategy.setCurrentSourceMessage(inMessage);
- propertyStrategy.setTargetMessage(exchange.getMessage());
- propertyStrategy.setExchange(exchange);
- session.setAtlasPropertyStrategy(propertyStrategy);
-
- DataSource[] sourceDataSources = session.getMapping().getDataSource().stream()
- .filter(ds -> ds.getDataSourceType() == DataSourceType.SOURCE)
- .toArray(DataSource[]::new);
- if (sourceDataSources.length == 0) {
- session.setDefaultSourceDocument(inMessage.getBody());
- return;
- }
-
- if (sourceDataSources.length == 1) {
- String docId = sourceDataSources[0].getId();
- Object payload = extractPayload(sourceDataSources[0], inMessage);
- if (docId == null || docId.isEmpty()) {
- session.setDefaultSourceDocument(payload);
- } else {
- session.setSourceDocument(docId, payload);
- propertyStrategy.setSourceMessage(docId, inMessage);
- }
- return;
- }
-
- Map<String, Message> sourceMessages = null;
- Map<String, Object> sourceDocuments = null;
- if (sourceMapName != null) {
- sourceMessages = exchange.getProperty(sourceMapName, Map.class);
- }
- if (sourceMessages == null) {
- Object body = inMessage.getBody();
- if (body instanceof Map) {
- sourceDocuments = (Map<String, Object>) body;
- } else {
- session.setDefaultSourceDocument(body);
- }
- }
- for (DataSource ds : sourceDataSources) {
- String docId = ds.getId();
- if (docId == null || docId.isEmpty()) {
- Object payload = extractPayload(ds, inMessage);
- session.setDefaultSourceDocument(payload);
- } else if (sourceMessages != null) {
- Object payload = extractPayload(ds, sourceMessages.get(docId));
- session.setSourceDocument(docId, payload);
- propertyStrategy.setSourceMessage(docId, sourceMessages.get(docId));
- } else if (sourceDocuments != null) {
- Object payload = sourceDocuments.get(docId);
- session.setSourceDocument(docId, payload);
- } else if (inMessage.getHeaders().containsKey(docId)) {
- Object payload = inMessage.getHeader(docId);
- session.setSourceDocument(docId, payload);
- } else if (exchange.getProperties().containsKey(docId)) {
- Object payload = exchange.getProperty(docId);
- session.setSourceDocument(docId, payload);
- } else {
- LOG.warn("Ignoring missing source document: '{}(ID:{})'", ds.getName(), ds.getId());
- }
- }
- }
-
- private Object extractPayload(final DataSource dataSource, Message message) {
- if (dataSource == null || message == null) {
- return null;
- }
- Object body = null;
-
- if (dataSource.getUri() != null
- && !(dataSource.getUri().startsWith("atlas:core")
- || dataSource.getUri().startsWith("atlas:java"))) {
- body = message.getBody(String.class);
- } else {
- body = message.getBody();
- }
-
- //Just in case, prepare for future calls
- MessageHelper.resetStreamCache(message);
-
- return body;
- }
-
- private void populateTargetDocuments(AtlasSession session, Exchange exchange) {
- Message message = exchange.getMessage();
-
- if (session.getMapping().getDataSource() == null) {
- return;
- }
- DataSource[] targetDataSources = session.getMapping().getDataSource().stream()
- .filter(ds -> ds.getDataSourceType() == DataSourceType.TARGET)
- .toArray(DataSource[]::new);
-
- if (targetDataSources.length == 0) {
- Object newBody = session.getDefaultTargetDocument();
- message.setBody(newBody);
- return;
- }
-
- if (targetDataSources.length == 1) {
- String docId = targetDataSources[0].getId();
- if (docId == null || docId.isEmpty()) {
- Object newBody = session.getDefaultTargetDocument();
- message.setBody(newBody);
- } else {
- Object newBody = session.getTargetDocument(docId);
- message.setBody(newBody);
- }
- setContentType(targetDataSources[0], message);
- return;
- }
-
- Map<String, Object> targetDocuments = new HashMap<>();
- for (DataSource ds : targetDataSources) {
- String docId = ds.getId();
- if (docId == null || docId.isEmpty()) {
- targetDocuments.put(io.atlasmap.api.AtlasConstants.DEFAULT_TARGET_DOCUMENT_ID,
- session.getDefaultTargetDocument());
- Object newBody = session.getDefaultTargetDocument();
- message.setBody(newBody);
- setContentType(ds, message);
- } else {
- targetDocuments.put(docId, session.getTargetDocument(docId));
- }
- }
- switch (targetMapMode) {
- case MAP:
- if (targetMapName != null) {
- exchange.setProperty(targetMapName, targetDocuments);
- } else {
- message.setBody(targetDocuments);
- }
- break;
- case MESSAGE_HEADER:
- targetDocuments.remove(io.atlasmap.api.AtlasConstants.DEFAULT_TARGET_DOCUMENT_ID);
- message.getHeaders().putAll(targetDocuments);
- break;
- case EXCHANGE_PROPERTY:
- targetDocuments.remove(io.atlasmap.api.AtlasConstants.DEFAULT_TARGET_DOCUMENT_ID);
- exchange.getProperties().putAll(targetDocuments);
- break;
- default:
- throw new IllegalArgumentException("Unknown targetMapMode: " + targetMapMode.name());
- }
- }
-
- private void setContentType(DataSource ds, Message message) {
- if (ds.getUri() == null) {
- return;
- }
- if (ds.getUri().startsWith("atlas:json")) {
- message.setHeader(Exchange.CONTENT_TYPE, CONTENT_TYPE_JSON);
- } else if (ds.getUri().startsWith("atlas:xml")) {
- message.setHeader(Exchange.CONTENT_TYPE, CONTENT_TYPE_XML);
- }
- }
-}
diff --git a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/CamelAtlasPropertyStrategy.java b/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/CamelAtlasPropertyStrategy.java
deleted file mode 100644
index 0170654870e..00000000000
--- a/components/camel-atlasmap/src/main/java/org/apache/camel/component/atlasmap/CamelAtlasPropertyStrategy.java
+++ /dev/null
@@ -1,92 +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.component.atlasmap;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import io.atlasmap.api.AtlasConversionException;
-import io.atlasmap.api.AtlasSession;
-import io.atlasmap.api.AtlasUnsupportedException;
-import io.atlasmap.core.DefaultAtlasPropertyStrategy;
-import io.atlasmap.v2.PropertyField;
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-
-/**
- * AtlasMap property strategy to map Camel message headers and exchange properties to/from AtlasMap properties.
- *
- */
-public class CamelAtlasPropertyStrategy extends DefaultAtlasPropertyStrategy {
-
- public static final String SCOPE_EXCHANGE_PROPERTY = "camelExchangeProperty";
- public static final String SCOPE_CURRENT_MESSAGE_HEADER = "current";
-
- private Exchange camelExchange;
- private Map<String, Message> sourceMessageMap = new HashMap<>();
- private Message camelTargetMessage;
-
- @Override
- public void readProperty(AtlasSession session, PropertyField propertyField)
- throws AtlasUnsupportedException, AtlasConversionException {
-
- String scope = propertyField.getScope();
- String key = propertyField.getName();
- Map<String, Object> target = null;
- if (scope == null && sourceMessageMap.containsKey(SCOPE_CURRENT_MESSAGE_HEADER)) {
- target = sourceMessageMap.get(SCOPE_CURRENT_MESSAGE_HEADER).getHeaders();
- } else if (SCOPE_EXCHANGE_PROPERTY.equals(scope)) {
- target = this.camelExchange.getProperties();
- } else if (sourceMessageMap.containsKey(scope)) {
- target = sourceMessageMap.get(scope).getHeaders();
- }
- if (target != null && target.containsKey(key)) {
- propertyField.setValue(target.get(key));
- } else {
- super.readProperty(session, propertyField);
- }
- }
-
- @Override
- public void writeProperty(AtlasSession session, PropertyField propertyField) {
- String scope = propertyField.getScope();
- String key = propertyField.getName();
- Object value = propertyField.getValue();
- if (SCOPE_EXCHANGE_PROPERTY.equals(scope)) {
- this.camelExchange.setProperty(key, value);
- } else {
- this.camelTargetMessage.setHeader(key, value);
- }
- }
-
- public void setExchange(Exchange ex) {
- this.camelExchange = ex;
- }
-
- public void setSourceMessage(String documentId, Message msg) {
- sourceMessageMap.put(documentId, msg);
- }
-
- public void setCurrentSourceMessage(Message msg) {
- sourceMessageMap.put(SCOPE_CURRENT_MESSAGE_HEADER, msg);
- }
-
- public void setTargetMessage(Message msg) {
- this.camelTargetMessage = msg;
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapEndpointTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapEndpointTest.java
deleted file mode 100644
index f89f2a8e4ea..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapEndpointTest.java
+++ /dev/null
@@ -1,201 +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.component.atlasmap;
-
-import java.io.ByteArrayInputStream;
-import java.util.ArrayList;
-import java.util.List;
-
-import io.atlasmap.api.AtlasContext;
-import io.atlasmap.api.AtlasSession;
-import io.atlasmap.v2.AtlasMapping;
-import io.atlasmap.v2.Audits;
-import io.atlasmap.v2.DataSource;
-import io.atlasmap.v2.DataSourceType;
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.junit.jupiter.api.Test;
-import org.mockito.invocation.InvocationOnMock;
-import org.mockito.stubbing.Answer;
-import org.opentest4j.AssertionFailedError;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertThrows;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.doAnswer;
-import static org.mockito.Mockito.doNothing;
-import static org.mockito.Mockito.spy;
-import static org.mockito.Mockito.when;
-
-public class AtlasMapEndpointTest {
- private static final Logger LOG = LoggerFactory.getLogger(AtlasMapEndpointTest.class);
-
- @Test
- public void testNoDataSource() throws Exception {
- perform(new ArrayList<>(), null, null, false);
- }
-
- @Test
- public void testDocId() throws Exception {
- List<DataSource> ds = new ArrayList<>();
- DataSource source = new DataSource();
- source.setDataSourceType(DataSourceType.SOURCE);
- source.setId("my-source-doc");
- ds.add(source);
- DataSource target = new DataSource();
- target.setDataSourceType(DataSourceType.TARGET);
- target.setId("my-target-doc");
- ds.add(target);
- perform(ds, "my-source-doc", "my-target-doc", false);
- }
-
- private void execute() throws Exception {
- perform(new ArrayList<>(), null, null, true);
- }
-
- @Test
- public void noConversionIfNoDataSource() throws Exception {
- assertThrows(AssertionFailedError.class, this::execute);
- }
-
- @Test
- public void noConversionIfJavaDataSource() throws Exception {
- final List<DataSource> dataSources = new ArrayList<>();
- final DataSource dataSource = new DataSource();
- dataSource.setDataSourceType(DataSourceType.SOURCE);
- dataSource.setUri("atlas:java:some.Type");
- dataSources.add(dataSource);
- assertThrows(AssertionFailedError.class, () -> {
- perform(dataSources, null, null, true);
- });
- }
-
- @Test
- public void doConversionIfJsonDataSource() throws Exception {
- final List<DataSource> dataSources = new ArrayList<>();
- final DataSource dataSource = new DataSource();
- dataSource.setDataSourceType(DataSourceType.SOURCE);
- dataSource.setUri("atlas:json:SomeType");
- dataSources.add(dataSource);
- perform(dataSources, null, null, true);
- }
-
- @Test
- public void noConversionIfJsonTargetDataSource() throws Exception {
- final List<DataSource> dataSources = new ArrayList<>();
- final DataSource dataSource = new DataSource();
- dataSource.setDataSourceType(DataSourceType.TARGET);
- dataSource.setUri("atlas:json:SomeType");
- dataSources.add(dataSource);
- assertThrows(AssertionFailedError.class, () -> {
- perform(dataSources, null, null, true);
- });
- }
-
- @Test
- public void doConversionIfXmlDataSource() throws Exception {
- final List<DataSource> dataSources = new ArrayList<>();
- final DataSource dataSource = new DataSource();
- dataSource.setDataSourceType(DataSourceType.SOURCE);
- dataSource.setUri("atlas:xml:SomeType");
- dataSources.add(dataSource);
- perform(dataSources, null, null, true);
- }
-
- @Test
- public void noConversionIfXmlTargetDataSource() throws Exception {
- final List<DataSource> dataSources = new ArrayList<>();
- final DataSource dataSource = new DataSource();
- dataSource.setDataSourceType(DataSourceType.TARGET);
- dataSource.setUri("atlas:xml:SomeType");
- dataSources.add(dataSource);
- assertThrows(AssertionFailedError.class, () -> {
- perform(dataSources, null, null, true);
- });
- }
-
- private void perform(List<DataSource> dataSources, String sourceDocId, String targetDocId, boolean fromStream)
- throws Exception {
- final AtlasMapping mapping = new AtlasMapping();
- mapping.getDataSource().addAll(dataSources);
- final AtlasContext context = spy(AtlasContext.class);
- final AtlasSession session = spy(AtlasSession.class);
- when(context.createSession()).thenReturn(session);
- when(session.getAtlasContext()).thenReturn(context);
- when(session.getMapping()).thenReturn(mapping);
- when(session.getAudits()).thenReturn(new Audits());
- final AtlasMapEndpoint endpoint = new AtlasMapEndpoint("atlasmap:test.xml", new AtlasMapComponent(), "test.xml");
- endpoint.setAtlasContext(context);
- final Exchange exchange = spy(Exchange.class);
- final Message inMessage = spy(Message.class);
- when(inMessage.getBody()).thenReturn(fromStream ? new ByteArrayInputStream("{test}".getBytes()) : "{test}");
- when(inMessage.getBody(String.class)).thenReturn("{test}");
- when(exchange.getIn()).thenReturn(inMessage);
- if (sourceDocId == null) {
- doAnswer(new Answer<Void>() {
- @Override
- public Void answer(InvocationOnMock invocation) {
- LOG.debug("setDefaultSourceDocument({})", invocation.getArgument(0).toString());
- assertEquals("{test}", invocation.getArgument(0).toString());
- return null;
- }
- }).when(session).setDefaultSourceDocument(any());
- } else {
- doAnswer(new Answer<Void>() {
- @Override
- public Void answer(InvocationOnMock invocation) {
- LOG.debug("setSourceDocument({}, {})", invocation.getArgument(0), invocation.getArgument(1));
- assertEquals(sourceDocId, invocation.getArgument(0));
- assertEquals("{test}", invocation.getArgument(1));
- return null;
- }
- }).when(session).setSourceDocument(any(), any());
- }
- final Message outMessage = spy(Message.class);
- doAnswer(new Answer<Void>() {
- @Override
- public Void answer(InvocationOnMock invocation) {
- LOG.debug("setBody({})", invocation.getArgument(0).toString());
- assertEquals("<target/>", invocation.getArgument(0));
- return null;
- }
- }).when(outMessage).setBody(any());
- doNothing().when(outMessage).setHeaders(any());
- if (targetDocId == null) {
- when(session.getDefaultTargetDocument()).thenAnswer(new Answer<Object>() {
- @Override
- public Object answer(InvocationOnMock invocation) throws Throwable {
- LOG.debug("getDefaultTargetDocument()");
- return "<target/>";
- }
- });
- } else {
- when(session.getTargetDocument(any())).thenAnswer(new Answer<Object>() {
- @Override
- public Object answer(InvocationOnMock invocation) throws Throwable {
- LOG.debug("getTargetDocument({})", invocation.getArgument(0).toString());
- assertEquals(targetDocId, invocation.getArgument(0));
- return "<target/>";
- }
- });
- }
- when(exchange.getMessage()).thenReturn(outMessage);
- endpoint.onExchange(exchange);
- }
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapExtractMappingsTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapExtractMappingsTest.java
deleted file mode 100644
index dd8c31cba5e..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapExtractMappingsTest.java
+++ /dev/null
@@ -1,71 +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.component.atlasmap;
-
-import java.io.ByteArrayInputStream;
-
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-import org.springframework.test.annotation.DirtiesContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class AtlasMapExtractMappingsTest extends CamelSpringTestSupport {
-
- private static final String EXPECTED_BODY = "{\"order\":{\"orderId\":\"A123\"}}";
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapExtractMappingsTest-context.xml");
- }
-
- @Test
- public void testXMLMappingsExtraction() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start",
- new ByteArrayInputStream("{ \"order\": { \"orderId\": \"A123\" }}".getBytes()));
-
- MockEndpoint.assertIsSatisfied(context);
-
- final Object body = result.getExchanges().get(0).getIn().getBody();
- assertEquals(EXPECTED_BODY, body);
- }
-
- @Test
- @DirtiesContext
- public void testXMLMappingsExtractionNumberedMappingFile() throws Exception {
- MockEndpoint resultN = getMockEndpoint("mock:result-n");
- resultN.setExpectedCount(1);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start-n",
- new ByteArrayInputStream("{ \"order\": { \"orderId\": \"A123\" }}".getBytes()));
-
- MockEndpoint.assertIsSatisfied(context);
-
- final Object body = resultN.getExchanges().get(0).getIn().getBody();
- assertEquals(EXPECTED_BODY, body);
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapForceReloadTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapForceReloadTest.java
deleted file mode 100644
index 1e856d61482..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapForceReloadTest.java
+++ /dev/null
@@ -1,102 +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.component.atlasmap;
-
-import java.io.InputStream;
-import java.io.StringReader;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.nio.file.StandardCopyOption;
-
-import javax.xml.transform.stream.StreamSource;
-import javax.xml.validation.Validator;
-
-import io.atlasmap.xml.core.schema.AtlasXmlSchemaSetParser;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class AtlasMapForceReloadTest extends CamelSpringTestSupport {
-
- private static final String INPUT_FILE = "json-source.json";
- private static final String EXPECTED_BODY = "{\"order\":{\"orderId\":\"123\"}}";
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapForceReloadTest-context.xml");
- }
-
- @Test
- public void testForceReloadDisabled() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- Files.copy(Paths.get("target/test-classes/adm/atlasmap-mapping.adm"),
- Paths.get("target/test-classes/atlasmap-mapping-force-reload.adm"),
- StandardCopyOption.REPLACE_EXISTING);
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- ClassLoader tccl = Thread.currentThread().getContextClassLoader();
- producerTemplate.sendBody("direct:start", tccl.getResourceAsStream(INPUT_FILE));
- MockEndpoint.assertIsSatisfied(context);
- final Object body = result.getExchanges().get(0).getIn().getBody();
- assertEquals(EXPECTED_BODY, body);
-
- result.reset();
- Files.copy(Paths.get("target/test-classes/adm/json-schema-source-to-xml-schema-target.adm"),
- Paths.get("target/test-classes/atlasmap-mapping-force-reload.adm"),
- StandardCopyOption.REPLACE_EXISTING);
- producerTemplate.sendBody("direct:start", tccl.getResourceAsStream(INPUT_FILE));
- MockEndpoint.assertIsSatisfied(context);
- final Object body2 = result.getExchanges().get(0).getIn().getBody();
- assertEquals(EXPECTED_BODY, body2);
- }
-
- @Test
- public void testForceReloadEnabled() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- Files.copy(Paths.get("target/test-classes/adm/atlasmap-mapping.adm"),
- Paths.get("target/test-classes/atlasmap-mapping-force-reload.adm"),
- StandardCopyOption.REPLACE_EXISTING);
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- ClassLoader tccl = Thread.currentThread().getContextClassLoader();
- producerTemplate.sendBody("direct:start-force-reload", tccl.getResourceAsStream(INPUT_FILE));
- MockEndpoint.assertIsSatisfied(context);
- final Object body = result.getExchanges().get(0).getIn().getBody();
- assertEquals(EXPECTED_BODY, body);
-
- result.reset();
- Files.copy(Paths.get("target/test-classes/adm/json-schema-source-to-xml-schema-target.adm"),
- Paths.get("target/test-classes/atlasmap-mapping-force-reload.adm"),
- StandardCopyOption.REPLACE_EXISTING);
- producerTemplate.sendBody("direct:start", tccl.getResourceAsStream(INPUT_FILE));
- MockEndpoint.assertIsSatisfied(context);
- final Object body2 = result.getExchanges().get(0).getIn().getBody();
- InputStream schemaIs = tccl.getResourceAsStream("xml-target-schemaset.xml");
- AtlasXmlSchemaSetParser schemaParser = new AtlasXmlSchemaSetParser(tccl);
- Validator validator = schemaParser.createSchema(schemaIs).newValidator();
- StreamSource source = new StreamSource(new StringReader(body2.toString()));
- validator.validate(source);
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJavaToJsonTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJavaToJsonTest.java
deleted file mode 100644
index 2164eed6c43..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJavaToJsonTest.java
+++ /dev/null
@@ -1,59 +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.component.atlasmap;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-
-public class AtlasMapJavaToJsonTest extends CamelSpringTestSupport {
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapJavaToJsonTest-context.xml");
- }
-
- @Test
- public void testMocksAreValid() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start", Util.generateMockTwitterStatus());
-
- MockEndpoint.assertIsSatisfied(context);
- Message msg = result.getExchanges().get(0).getIn();
- assertEquals("application/json", msg.getHeader(Exchange.CONTENT_TYPE));
- Object body = msg.getBody();
- assertEquals(String.class, body.getClass());
- ObjectMapper mapper = new ObjectMapper();
- JsonNode sfJson = mapper.readTree((String) body);
- assertNotNull(sfJson.get("TwitterScreenName__c"));
- assertEquals("bobvila1982", sfJson.get("TwitterScreenName__c").asText());
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonTest.java
deleted file mode 100644
index a00c97ca1bd..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonTest.java
+++ /dev/null
@@ -1,56 +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.component.atlasmap;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class AtlasMapJsonTest extends CamelSpringTestSupport {
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapJsonTest-context.xml");
- }
-
- @Test
- public void testMocksAreValid() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start", Util.generateMockTwitterStatus());
-
- MockEndpoint.assertIsSatisfied(context);
- Object body = result.getExchanges().get(0).getIn().getBody();
- assertEquals(String.class, body.getClass());
- ObjectMapper mapper = new ObjectMapper();
- JsonNode outJson = mapper.readTree((String) body);
- assertEquals("Bob", outJson.get("FirstName").asText());
- assertEquals("Vila", outJson.get("LastName").asText());
- assertEquals("bobvila1982", outJson.get("Title").asText());
- assertEquals("Let's build a house!", outJson.get("Description").asText());
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonToJavaTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonToJavaTest.java
deleted file mode 100644
index f26c31e99ab..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonToJavaTest.java
+++ /dev/null
@@ -1,50 +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.component.atlasmap;
-
-import java.io.ByteArrayInputStream;
-
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class AtlasMapJsonToJavaTest extends CamelSpringTestSupport {
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapJsonToJavaTest-context.xml");
- }
-
- @Test
- public void testMocksAreValid() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- final ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start", new ByteArrayInputStream("{\"field1\":\"value1\"}".getBytes()));
-
- MockEndpoint.assertIsSatisfied(context);
- final Object body = result.getExchanges().get(0).getIn().getBody();
- assertEquals(Pojo.class, body.getClass());
- assertEquals("value1", ((Pojo) body).getField1());
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonToXmlSchemaTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonToXmlSchemaTest.java
deleted file mode 100644
index 5f071318fd9..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapJsonToXmlSchemaTest.java
+++ /dev/null
@@ -1,67 +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.component.atlasmap;
-
-import java.io.InputStream;
-import java.io.StringReader;
-
-import javax.xml.transform.stream.StreamSource;
-import javax.xml.validation.Validator;
-
-import io.atlasmap.xml.core.schema.AtlasXmlSchemaSetParser;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-
-public class AtlasMapJsonToXmlSchemaTest extends CamelSpringTestSupport {
- private static final Logger LOG = LoggerFactory.getLogger(AtlasMapJsonToXmlSchemaTest.class);
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapJsonToXmlSchemaTest-context.xml");
- }
-
- @Test
- public void test() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- final ProducerTemplate producerTemplate = context.createProducerTemplate();
- ClassLoader tccl = Thread.currentThread().getContextClassLoader();
- InputStream payloadIs = tccl.getResourceAsStream("json-source.json");
- producerTemplate.sendBody("direct:start", payloadIs);
-
- MockEndpoint.assertIsSatisfied(context);
- final String body = result.getExchanges().get(0).getIn().getBody(String.class);
- assertNotNull(body);
- LOG.debug(">>>>> {}", body);
-
- InputStream schemaIs = tccl.getResourceAsStream("xml-target-schemaset.xml");
- AtlasXmlSchemaSetParser schemaParser = new AtlasXmlSchemaSetParser(tccl);
- Validator validator = schemaParser.createSchema(schemaIs).newValidator();
- StreamSource source = new StreamSource(new StringReader(body));
- validator.validate(source);
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapMultiDocsTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapMultiDocsTest.java
deleted file mode 100644
index d092fe444a8..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapMultiDocsTest.java
+++ /dev/null
@@ -1,190 +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.component.atlasmap;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import io.atlasmap.java.test.SourceContact;
-import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.support.DefaultMessage;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-import org.xmlunit.builder.Input;
-import org.xmlunit.xpath.JAXPXPathEngine;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class AtlasMapMultiDocsTest extends CamelSpringTestSupport {
-
- private static final String JSON_SOURCE = "{" +
- "\"firstName\": \"JsonFirstName\"," +
- "\"lastName\": \"JsonLastName\"," +
- "\"phoneNumber\": \"JsonPhoneNumber\"," +
- "\"zipCode\": \"JsonZipCode\"" +
- "}";
-
- private static final String XML_SOURCE = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
- "<ns:Contact xmlns:ns=\"http://atlasmap.io/xml/test/v2\"\n" +
- " xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"\n" +
- " firstName=\"XmlFirstName\" lastName=\"XmlLastName\"\n" +
- " phoneNumber=\"XmlPhoneNumber\" zipCode=\"XmlZipCode\" />\n";
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapMultiDocsTest-context.xml");
- }
-
- @Test
- public void test() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- Map<String, Message> sourceMap = new HashMap<>();
- SourceContact javaSource = new SourceContact();
- javaSource.setFirstName("JavaFirstName");
- javaSource.setLastName("JavaLastName");
- javaSource.setPhoneNumber("JavaPhoneNumber");
- javaSource.setZipCode("JavaZipCode");
- Message msg = new DefaultMessage(context);
- msg.setBody(javaSource);
- msg.setHeader("testProp", "java-source-header");
- sourceMap.put("DOCID:JAVA:CONTACT:S", msg);
- msg = new DefaultMessage(context);
- msg.setBody(JSON_SOURCE);
- msg.setHeader("testProp", "json-source-header");
- sourceMap.put("DOCID:JSON:CONTACT:S", msg);
- msg = new DefaultMessage(context);
- msg.setBody(XML_SOURCE);
- msg.setHeader("testProp", "xml-source-header");
- sourceMap.put("DOCID:XML:CONTACT:S", msg);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBodyAndProperty("direct:start", null, "CAPTURED_OUT_MESSAGES_MAP", sourceMap);
-
- MockEndpoint.assertIsSatisfied(context);
- Exchange exchange = result.getExchanges().get(0);
- Map<?, ?> targetMap = exchange.getProperty("TARGET_MESSAGES_MAP", Map.class);
-
- verifyTargetDocs(targetMap);
-
- assertEquals("java-source-header", exchange.getProperty("target-exchange"));
- assertEquals("json-source-header", exchange.getProperty("testProp"));
- assertEquals("xml-source-header", exchange.getIn().getHeader("testProp"));
- }
-
- @Test
- public void testBody() throws Exception {
- MockEndpoint resultBody = getMockEndpoint("mock:result-body");
- resultBody.setExpectedCount(1);
-
- Map<String, Object> sourceMap = new HashMap<>();
- SourceContact javaSource = new SourceContact();
- javaSource.setFirstName("JavaFirstName");
- javaSource.setLastName("JavaLastName");
- javaSource.setPhoneNumber("JavaPhoneNumber");
- javaSource.setZipCode("JavaZipCode");
- sourceMap.put("DOCID:JAVA:CONTACT:S", javaSource);
- sourceMap.put("DOCID:JSON:CONTACT:S", JSON_SOURCE);
- sourceMap.put("DOCID:XML:CONTACT:S", XML_SOURCE);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start-body", sourceMap);
-
- MockEndpoint.assertIsSatisfied(context);
- Exchange exchange = resultBody.getExchanges().get(0);
- Map<?, ?> targetMap = exchange.getIn().getBody(Map.class);
-
- verifyTargetDocs(targetMap);
- }
-
- @Test
- public void testHeaderDocs() throws Exception {
- MockEndpoint resultBody = getMockEndpoint("mock:result-body");
- resultBody.setExpectedCount(1);
-
- Map<String, Object> sourceMap = new HashMap<>();
- SourceContact javaSource = new SourceContact();
- javaSource.setFirstName("JavaFirstName");
- javaSource.setLastName("JavaLastName");
- javaSource.setPhoneNumber("JavaPhoneNumber");
- javaSource.setZipCode("JavaZipCode");
- sourceMap.put("DOCID:JAVA:CONTACT:S", javaSource);
- sourceMap.put("DOCID:JSON:CONTACT:S", JSON_SOURCE);
- sourceMap.put("DOCID:XML:CONTACT:S", XML_SOURCE);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBodyAndHeaders("direct:start-header", null, sourceMap);
-
- MockEndpoint.assertIsSatisfied(context);
- Exchange exchange = resultBody.getExchanges().get(0);
- verifyTargetDocs(exchange.getIn().getHeaders());
- }
-
- @Test
- public void testExchangePropertyDocs() throws Exception {
- MockEndpoint resultBody = getMockEndpoint("mock:result-body");
- resultBody.setExpectedCount(1);
-
- Map<String, Object> sourceMap = new HashMap<>();
- SourceContact javaSource = new SourceContact();
- javaSource.setFirstName("JavaFirstName");
- javaSource.setLastName("JavaLastName");
- javaSource.setPhoneNumber("JavaPhoneNumber");
- javaSource.setZipCode("JavaZipCode");
- sourceMap.put("DOCID:JAVA:CONTACT:S", javaSource);
- sourceMap.put("DOCID:JSON:CONTACT:S", JSON_SOURCE);
- sourceMap.put("DOCID:XML:CONTACT:S", XML_SOURCE);
-
- Endpoint ep = context.getEndpoint("direct:start-exchange-property");
- Exchange ex = ep.createExchange();
- ex.getProperties().putAll(sourceMap);
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.send(ep, ex);
-
- MockEndpoint.assertIsSatisfied(context);
- Exchange exchange = resultBody.getExchanges().get(0);
- verifyTargetDocs(exchange.getProperties());
- }
-
- private void verifyTargetDocs(Map<?, ?> targetMap) throws Exception {
- String jsonTarget = (String) targetMap.get("DOCID:JSON:CONTACT:T");
- ObjectMapper mapper = new ObjectMapper();
- JsonNode jsonTargetNode = mapper.readTree(jsonTarget);
- assertEquals("JsonFirstName", jsonTargetNode.get("firstName").asText());
- assertEquals("JavaLastName", jsonTargetNode.get("lastName").asText());
- assertEquals("XmlPhoneNumber", jsonTargetNode.get("phoneNumber").asText());
-
- String xmlTarget = (String) targetMap.get("DOCID:XML:CONTACT:T");
- HashMap<String, String> ns = new HashMap<>();
- ns.put("ns", "http://atlasmap.io/xml/test/v2");
- JAXPXPathEngine xpath = new JAXPXPathEngine();
- xpath.setNamespaceContext(ns);
- assertEquals("XmlFirstName", xpath.evaluate("/Contact/@firstName", Input.fromString(xmlTarget).build()));
- assertEquals("JsonLastName", xpath.evaluate("/Contact/@lastName", Input.fromString(xmlTarget).build()));
- assertEquals("JavaPhoneNumber", xpath.evaluate("/Contact/@phoneNumber", Input.fromString(xmlTarget).build()));
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapMultiNSTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapMultiNSTest.java
deleted file mode 100644
index 176875f4685..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapMultiNSTest.java
+++ /dev/null
@@ -1,71 +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.component.atlasmap;
-
-import io.atlasmap.java.test.SourceContact;
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Assertions;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-import org.xmlunit.builder.DiffBuilder;
-import org.xmlunit.builder.Input;
-import org.xmlunit.diff.Diff;
-
-public class AtlasMapMultiNSTest extends CamelSpringTestSupport {
-
- private static final String XML_EXPECTED = "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n" +
- "<tns:request xmlns:tns=\"http://syndesis.io/v1/swagger-connector-template/request\">\n"
- +
- " <tns:body>\n" +
- " <Pet>\n" +
- " <name>Jackson</name>\n" +
- " </Pet>\n" +
- " </tns:body>\n" +
- "</tns:request>";
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapMultiNSTest-context.xml");
- }
-
- @Test
- public void test() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- SourceContact c = new SourceContact();
- c.setFirstName("Jackson");
- producerTemplate.sendBody("direct:start", c);
-
- MockEndpoint.assertIsSatisfied(context);
- Message message = result.getExchanges().get(0).getIn();
- Assertions.assertEquals("application/xml", message.getHeader(Exchange.CONTENT_TYPE));
- String out = message.getBody(String.class);
- Assertions.assertNotNull(out);
- Diff d = DiffBuilder.compare(Input.fromString(XML_EXPECTED).build())
- .withTest(Input.fromString(out).build())
- .ignoreWhitespace().build();
- Assertions.assertFalse(d.hasDifferences(), d.toString() + ": " + out);
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapSingleDocTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapSingleDocTest.java
deleted file mode 100644
index c44e6a37785..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapSingleDocTest.java
+++ /dev/null
@@ -1,59 +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.component.atlasmap;
-
-import java.util.Map;
-
-import io.atlasmap.java.test.SourceContact;
-import io.atlasmap.java.test.TargetContact;
-import org.apache.camel.Exchange;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class AtlasMapSingleDocTest extends CamelSpringTestSupport {
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapSingleDocTest-context.xml");
- }
-
- @Test
- public void test() throws Exception {
- SourceContact javaSource = new SourceContact();
- javaSource.setFirstName("JavaFirstName");
- javaSource.setLastName("JavaLastName");
- javaSource.setPhoneNumber("JavaPhoneNumber");
- javaSource.setZipCode("JavaZipCode");
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start", javaSource);
-
- MockEndpoint.assertIsSatisfied(context);
- MockEndpoint result = getMockEndpoint("mock:result");
- Exchange exchange = result.getExchanges().get(0);
- Map<?, ?> targetMap = exchange.getIn().getBody(Map.class);
- TargetContact javaTarget = (TargetContact) targetMap.get("DOCID:JAVA:CONTACT:T");
- assertEquals("JavaFirstName", javaTarget.getFirstName());
-
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapTest.java
deleted file mode 100644
index 95284ae8368..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapTest.java
+++ /dev/null
@@ -1,81 +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.component.atlasmap;
-
-import com.fasterxml.jackson.databind.JsonNode;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-import twitter4j.v1.Status;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNull;
-import static org.mockito.Mockito.when;
-
-public class AtlasMapTest extends CamelSpringTestSupport {
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapTest-context.xml");
- }
-
- @Test
- public void testMocksAreValid() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start", Util.generateMockTwitterStatus());
-
- MockEndpoint.assertIsSatisfied(context);
- Object body = result.getExchanges().get(0).getIn().getBody();
- assertEquals(String.class, body.getClass());
- ObjectMapper mapper = new ObjectMapper();
- JsonNode outJson = mapper.readTree((String) body);
- assertEquals("Bob", outJson.get("FirstName").asText());
- assertEquals("Vila", outJson.get("LastName").asText());
- assertEquals("bobvila1982", outJson.get("Title").asText());
- assertEquals("Let's build a house!", outJson.get("Description").asText());
- assertEquals("const foobar", outJson.get("Constant").asText());
- }
-
- @Test
- public void testSeparateNotSucceed() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- ProducerTemplate producerTemplate = context.createProducerTemplate();
- Status s = Util.generateMockTwitterStatus();
- when(s.getUser().getName()).thenReturn("BobVila");
- producerTemplate.sendBody("direct:start", s);
-
- MockEndpoint.assertIsSatisfied(context);
- Object body = result.getExchanges().get(0).getIn().getBody();
- assertEquals(String.class, body.getClass());
- ObjectMapper mapper = new ObjectMapper();
- JsonNode outJson = mapper.readTree((String) body);
- assertEquals("BobVila", outJson.get("FirstName").asText());
- assertNull(outJson.get("LastName"));
- assertEquals("bobvila1982", outJson.get("Title").asText());
- assertEquals("Let's build a house!", outJson.get("Description").asText());
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapXmlToXmlDefaultNsTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapXmlToXmlDefaultNsTest.java
deleted file mode 100644
index 2d09c298bdb..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapXmlToXmlDefaultNsTest.java
+++ /dev/null
@@ -1,64 +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.component.atlasmap;
-
-import java.io.ByteArrayInputStream;
-
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-import org.xmlunit.builder.DiffBuilder;
-import org.xmlunit.builder.Input;
-import org.xmlunit.diff.Diff;
-
-import static org.junit.jupiter.api.Assertions.assertFalse;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-
-public class AtlasMapXmlToXmlDefaultNsTest extends CamelSpringTestSupport {
-
- private static final String XML_EXPECTED
- = "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?><tns:Patient xmlns:tns=\"http://hl7.org/fhir\"><tns:id value=\"101138\"/></tns:Patient>";
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapXmlToXmlTest-context.xml");
- }
-
- @Test
- public void testMocksAreValid() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- final ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start", new ByteArrayInputStream(
- "<Patient xmlns=\"http://hl7.org/fhir\"><id value=\"101138\"></id></Patient>".getBytes()));
-
- MockEndpoint.assertIsSatisfied(context);
- final String body = result.getExchanges().get(0).getIn().getBody(String.class);
-
- assertNotNull(body);
-
- Diff d = DiffBuilder.compare(Input.fromString(XML_EXPECTED).build())
- .withTest(Input.fromString(body).build())
- .ignoreWhitespace().build();
- assertFalse(d.hasDifferences(), d.toString() + ": " + body);
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapXmlToXmlTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapXmlToXmlTest.java
deleted file mode 100644
index f6b3343d72b..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/AtlasMapXmlToXmlTest.java
+++ /dev/null
@@ -1,66 +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.component.atlasmap;
-
-import java.io.ByteArrayInputStream;
-
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.test.spring.junit5.CamelSpringTestSupport;
-import org.junit.jupiter.api.Test;
-import org.springframework.context.support.AbstractApplicationContext;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-import org.springframework.test.annotation.DirtiesContext;
-import org.xmlunit.builder.DiffBuilder;
-import org.xmlunit.builder.Input;
-import org.xmlunit.diff.Diff;
-
-import static org.junit.jupiter.api.Assertions.assertFalse;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-
-public class AtlasMapXmlToXmlTest extends CamelSpringTestSupport {
-
- private static final String XML_EXPECTED
- = "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?><tns:Patient xmlns:tns=\"http://hl7.org/fhir\"><tns:id value=\"101138\"/></tns:Patient>";
-
- @Override
- protected AbstractApplicationContext createApplicationContext() {
- return new ClassPathXmlApplicationContext("context/AtlasMapXmlToXmlTest-context.xml");
- }
-
- @Test
- @DirtiesContext
- public void testMocksAreValid() throws Exception {
- MockEndpoint result = getMockEndpoint("mock:result");
- result.setExpectedCount(1);
-
- final ProducerTemplate producerTemplate = context.createProducerTemplate();
- producerTemplate.sendBody("direct:start", new ByteArrayInputStream(
- "<tns:Patient xmlns:tns=\"http://hl7.org/fhir\"><tns:id value=\"101138\"></tns:id></tns:Patient>".getBytes()));
-
- MockEndpoint.assertIsSatisfied(context);
- final String body = result.getExchanges().get(0).getIn().getBody(String.class);
-
- assertNotNull(body);
-
- Diff d = DiffBuilder.compare(Input.fromString(XML_EXPECTED).build())
- .withTest(Input.fromString(body).build())
- .ignoreWhitespace().build();
- assertFalse(d.hasDifferences(), d.toString() + ": " + body);
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/CamelAtlasPropertyStrategyTest.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/CamelAtlasPropertyStrategyTest.java
deleted file mode 100644
index 68ea4edd9a6..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/CamelAtlasPropertyStrategyTest.java
+++ /dev/null
@@ -1,90 +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.component.atlasmap;
-
-import io.atlasmap.api.AtlasSession;
-import io.atlasmap.core.DefaultAtlasSession;
-import io.atlasmap.v2.PropertyField;
-import org.apache.camel.impl.DefaultCamelContext;
-import org.apache.camel.support.DefaultExchange;
-import org.apache.camel.support.DefaultMessage;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNull;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-public class CamelAtlasPropertyStrategyTest {
-
- @Test
- public void testRead() throws Exception {
- CamelAtlasPropertyStrategy strategy = new CamelAtlasPropertyStrategy();
- DefaultCamelContext context = new DefaultCamelContext();
- DefaultExchange exchange = new DefaultExchange(context);
- exchange.setProperty("testProp", "testProp-exchangeProperty");
- strategy.setExchange(exchange);
- DefaultMessage currentMessage = new DefaultMessage(exchange);
- currentMessage.setHeader("testProp", "testProp-currentMessage");
- strategy.setCurrentSourceMessage(currentMessage);
- DefaultMessage message1 = new DefaultMessage(exchange);
- message1.setHeader("testProp", "testProp-message1");
- strategy.setSourceMessage("Doc1", message1);
- DefaultMessage message2 = new DefaultMessage(exchange);
- message2.setHeader("testProp", "testProp-message2");
- strategy.setSourceMessage("Doc2", message2);
- AtlasSession session = mock(AtlasSession.class);
- when(session.getAtlasPropertyStrategy()).thenReturn(strategy);
- PropertyField propertyField = new PropertyField();
- propertyField.setName("testProp");
- strategy.readProperty(session, propertyField);
- assertEquals("testProp-currentMessage", propertyField.getValue());
- propertyField.setScope(CamelAtlasPropertyStrategy.SCOPE_EXCHANGE_PROPERTY);
- strategy.readProperty(session, propertyField);
- assertEquals("testProp-exchangeProperty", propertyField.getValue());
- propertyField.setScope("Doc1");
- strategy.readProperty(session, propertyField);
- assertEquals("testProp-message1", propertyField.getValue());
- propertyField.setScope("Doc2");
- strategy.readProperty(session, propertyField);
- assertEquals("testProp-message2", propertyField.getValue());
- }
-
- @Test
- public void testWrite() throws Exception {
- CamelAtlasPropertyStrategy strategy = new CamelAtlasPropertyStrategy();
- DefaultCamelContext context = new DefaultCamelContext();
- DefaultExchange exchange = new DefaultExchange(context);
- strategy.setExchange(exchange);
- DefaultMessage message = new DefaultMessage(exchange);
- strategy.setTargetMessage(message);
- PropertyField propertyField = new PropertyField();
- propertyField.setName("testProp-message");
- propertyField.setValue("testValue");
- AtlasSession session = mock(DefaultAtlasSession.class);
- when(session.getAtlasPropertyStrategy()).thenReturn(strategy);
- strategy.writeProperty(session, propertyField);
- propertyField.setName("testProp-exchange");
- propertyField.setScope(CamelAtlasPropertyStrategy.SCOPE_EXCHANGE_PROPERTY);
- strategy.writeProperty(session, propertyField);
- assertEquals("testValue", message.getHeader("testProp-message"));
- assertNull(message.getHeader("testProp-exchange"));
- assertNull(exchange.getProperty("testProp-message"));
- assertEquals("testValue", exchange.getProperty("testProp-exchange"));
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/Pojo.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/Pojo.java
deleted file mode 100644
index 7edddaacdaf..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/Pojo.java
+++ /dev/null
@@ -1,31 +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.component.atlasmap;
-
-public class Pojo {
-
- private String field1;
-
- public String getField1() {
- return field1;
- }
-
- public void setField1(final String field1) {
- this.field1 = field1;
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/Util.java b/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/Util.java
deleted file mode 100644
index 08b88178fa0..00000000000
--- a/components/camel-atlasmap/src/test/java/org/apache/camel/component/atlasmap/Util.java
+++ /dev/null
@@ -1,40 +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.component.atlasmap;
-
-import twitter4j.v1.Status;
-import twitter4j.v1.User;
-
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-public final class Util {
-
- private Util() {
- }
-
- public static Status generateMockTwitterStatus() {
- Status status = mock(Status.class);
- User user = mock(User.class);
- when(user.getName()).thenReturn("Bob Vila");
- when(user.getScreenName()).thenReturn("bobvila1982");
- when(status.getUser()).thenReturn(user);
- when(status.getText()).thenReturn("Let's build a house!");
- return status;
- }
-
-}
diff --git a/components/camel-atlasmap/src/test/resources/adm/atlasmap-mapping-n.adm b/components/camel-atlasmap/src/test/resources/adm/atlasmap-mapping-n.adm
deleted file mode 100644
index e6bf68d16a4..00000000000
Binary files a/components/camel-atlasmap/src/test/resources/adm/atlasmap-mapping-n.adm and /dev/null differ
diff --git a/components/camel-atlasmap/src/test/resources/adm/atlasmap-mapping.adm b/components/camel-atlasmap/src/test/resources/adm/atlasmap-mapping.adm
deleted file mode 100644
index 0744b9ecddb..00000000000
Binary files a/components/camel-atlasmap/src/test/resources/adm/atlasmap-mapping.adm and /dev/null differ
diff --git a/components/camel-atlasmap/src/test/resources/adm/json-schema-source-to-xml-schema-target.adm b/components/camel-atlasmap/src/test/resources/adm/json-schema-source-to-xml-schema-target.adm
deleted file mode 100644
index 645094a6bac..00000000000
Binary files a/components/camel-atlasmap/src/test/resources/adm/json-schema-source-to-xml-schema-target.adm and /dev/null differ
diff --git a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-java-to-json.json b/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-java-to-json.json
deleted file mode 100644
index 95a327cdb59..00000000000
--- a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-java-to-json.json
+++ /dev/null
@@ -1,56 +0,0 @@
-{
- "AtlasMapping": {
- "jsonType": "io.atlasmap.v2.AtlasMapping",
- "dataSource": [
- {
- "jsonType": "io.atlasmap.v2.DataSource",
- "id": "twitter4j.Status",
- "uri": "atlas:java?className=twitter4j.Status",
- "dataSourceType": "SOURCE"
- },
- {
- "jsonType": "io.atlasmap.json.v2.JsonDataSource",
- "id": "Contact",
- "uri": "atlas:json:Contact",
- "dataSourceType": "TARGET",
- "template": null
- }
- ],
- "mappings": {
- "mapping": [
- {
- "jsonType": "io.atlasmap.v2.Mapping",
- "mappingType": "MAP",
- "inputField": [
- {
- "jsonType": "io.atlasmap.java.v2.JavaField",
- "name": "screenName",
- "path": "/user/screenName",
- "fieldType": "STRING",
- "docId": "twitter4j.Status"
- }
- ],
- "outputField": [
- {
- "jsonType": "io.atlasmap.json.v2.JsonComplexType",
- "name": "TwitterScreenName__c",
- "path": "/TwitterScreenName__c",
- "fieldType": "STRING",
- "docId": "Contact",
- "userCreated": false
- }
- ]
- }
- ]
- },
- "name": "UI.246440",
- "lookupTables": {
- "lookupTable": [
- ]
- },
- "properties": {
- "property": [
- ]
- }
- }
-}
diff --git a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-json-to-java.json b/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-json-to-java.json
deleted file mode 100644
index c688af550d7..00000000000
--- a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-json-to-java.json
+++ /dev/null
@@ -1,56 +0,0 @@
-{
- "AtlasMapping": {
- "jsonType": "io.atlasmap.v2.AtlasMapping",
- "dataSource": [
- {
- "jsonType": "io.atlasmap.json.v2.JsonDataSource",
- "id": "Contact",
- "uri": "atlas:json:Json",
- "dataSourceType": "SOURCE",
- "template": null
- },
- {
- "jsonType": "io.atlasmap.v2.DataSource",
- "id": "twitter4j.Status",
- "uri": "atlas:java?className=org.apache.camel.component.atlasmap.Pojo",
- "dataSourceType": "TARGET"
- }
- ],
- "mappings": {
- "mapping": [
- {
- "jsonType": "io.atlasmap.v2.Mapping",
- "mappingType": "MAP",
- "inputField": [
- {
- "jsonType": "io.atlasmap.json.v2.JsonComplexType",
- "name": "field1",
- "path": "/field1",
- "fieldType": "STRING",
- "docId": "Contact",
- "userCreated": false
- }
- ],
- "outputField": [
- {
- "jsonType": "io.atlasmap.java.v2.JavaField",
- "name": "field1",
- "path": "/field1",
- "fieldType": "STRING",
- "docId": "twitter4j.Status"
- }
- ]
- }
- ]
- },
- "name": "UI.246440",
- "lookupTables": {
- "lookupTable": [
- ]
- },
- "properties": {
- "property": [
- ]
- }
- }
-}
diff --git a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-multidocs.json b/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-multidocs.json
deleted file mode 100644
index 266bd216ec5..00000000000
--- a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-multidocs.json
+++ /dev/null
@@ -1,255 +0,0 @@
-{
- "AtlasMapping" : {
- "jsonType" : "io.atlasmap.v2.AtlasMapping",
- "dataSource" : [ {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JAVA:CONTACT:S",
- "uri" : "atlas:java?className=io.atlasmap.java.test.SourceContact",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JSON:CONTACT:S",
- "uri" : "atlas:json:JSONContact",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:XML:CONTACT:S",
- "uri" : "atlas:xml:XMLContact",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JAVA:CONTACT:T",
- "uri" : "atlas:java?className=io.atlasmap.java.test.TargetContact",
- "dataSourceType" : "TARGET"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JSON:CONTACT:T",
- "uri" : "atlas:json:JSONContact",
- "dataSourceType" : "TARGET"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:XML:CONTACT:T",
- "uri" : "atlas:xml:XMLContact",
- "dataSourceType" : "TARGET"
- } ],
- "mappings" : {
- "mapping" : [ {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:S",
- "path" : "/firstName",
- "fieldType" : "STRING",
- "name" : "firstName",
- "getMethod" : "getFirstName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:T",
- "path" : "/firstName",
- "fieldType" : "STRING",
- "name" : "firstName",
- "setMethod" : "setFirstName"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:S",
- "path" : "/lastName",
- "fieldType" : "STRING",
- "name" : "lastName",
- "getMethod" : "getLastName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "docId" : "DOCID:JSON:CONTACT:T",
- "path" : "/lastName",
- "fieldType" : "STRING",
- "name" : "lastName"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:S",
- "path" : "/phoneNumber",
- "fieldType" : "STRING",
- "name" : "phoneNumber",
- "getMethod" : "getPhoneNumber"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.xml.v2.XmlField",
- "docId" : "DOCID:XML:CONTACT:T",
- "path" : "/Contact/@phoneNumber",
- "fieldType" : "STRING",
- "name" : "phoneNumber"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "docId" : "DOCID:JSON:CONTACT:S",
- "path" : "/firstName",
- "fieldType" : "STRING",
- "name" : "firstName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "docId" : "DOCID:JSON:CONTACT:T",
- "path" : "/firstName",
- "fieldType" : "STRING",
- "name" : "firstName"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "docId" : "DOCID:JSON:CONTACT:S",
- "path" : "/lastName",
- "fieldType" : "STRING",
- "name" : "lastName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.xml.v2.XmlField",
- "docId" : "DOCID:XML:CONTACT:T",
- "path" : "/Contact/@lastName",
- "fieldType" : "STRING",
- "name" : "lastName"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "docId" : "DOCID:JSON:CONTACT:S",
- "path" : "/phoneNumber",
- "fieldType" : "STRING",
- "name" : "phoneNumber"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:T",
- "path" : "/phoneNumber",
- "fieldType" : "STRING",
- "name" : "phoneNumber",
- "setMethod" : "setPhoneNumber"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.xml.v2.XmlField",
- "docId" : "DOCID:XML:CONTACT:S",
- "path" : "/Contact/@firstName",
- "fieldType" : "STRING",
- "name" : "firstName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.xml.v2.XmlField",
- "docId" : "DOCID:XML:CONTACT:T",
- "path" : "/Contact/@firstName",
- "fieldType" : "STRING",
- "name" : "firstName"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.xml.v2.XmlField",
- "docId" : "DOCID:XML:CONTACT:S",
- "path" : "/Contact/@lastName",
- "fieldType" : "STRING",
- "name" : "lastName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:T",
- "path" : "/lastName",
- "fieldType" : "STRING",
- "name" : "lastName",
- "setMethod" : "setLastName"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.xml.v2.XmlField",
- "docId" : "DOCID:XML:CONTACT:S",
- "path" : "/Contact/@phoneNumber",
- "fieldType" : "STRING",
- "name" : "phoneNumber"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "docId" : "DOCID:JSON:CONTACT:T",
- "path" : "/phoneNumber",
- "fieldType" : "STRING",
- "name" : "phoneNumber"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.v2.PropertyField",
- "path" : "/testProp",
- "fieldType" : "STRING",
- "scope" : "DOCID:JAVA:CONTACT:S",
- "name" : "testProp"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.v2.PropertyField",
- "path" : "/target-exchange",
- "fieldType" : "STRING",
- "scope" : "camelExchangeProperty",
- "name" : "target-exchange"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.v2.PropertyField",
- "path" : "/testProp",
- "fieldType" : "STRING",
- "scope" : "DOCID:JSON:CONTACT:S",
- "name" : "testProp"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.v2.PropertyField",
- "path" : "/testProp",
- "fieldType" : "STRING",
- "scope" : "camelExchangeProperty",
- "name" : "testProp"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.v2.PropertyField",
- "path" : "/testProp",
- "fieldType" : "STRING",
- "scope" : "DOCID:XML:CONTACT:S",
- "name" : "testProp"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.v2.PropertyField",
- "path" : "/testProp",
- "fieldType" : "STRING",
- "name" : "testProp"
- } ]
- } ]
- },
- "lookupTables" : {
- "lookupTable" : [ ]
- },
- "properties" : {
- "property" : [ ]
- },
- "name" : "mockMapping"
- }
-}
diff --git a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-multins.json b/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-multins.json
deleted file mode 100644
index 5e02d89c8b4..00000000000
--- a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-multins.json
+++ /dev/null
@@ -1,52 +0,0 @@
-{
- "AtlasMapping" : {
- "jsonType" : "io.atlasmap.v2.AtlasMapping",
- "dataSource" : [ {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "SourceContact",
- "uri" : "atlas:java:SourceContact?className=io.atlasmap.java.test.SourceContact",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.xml.v2.XmlDataSource",
- "id" : "XMLSchemaTarget",
- "uri" : "atlas:xml:XMLSchemaTarget",
- "dataSourceType" : "TARGET",
- "xmlNamespaces" : {
- "xmlNamespace" : [ {
- "alias" : "tns",
- "uri" : "http://syndesis.io/v1/swagger-connector-template/request"
- } ]
- }
- } ],
- "mappings" : {
- "mapping" : [ {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "SourceContact",
- "path" : "/firstName",
- "fieldType" : "STRING",
- "name" : "firstName",
- "getMethod" : "getFirstName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.xml.v2.XmlField",
- "docId" : "XMLSchemaTarget",
- "path" : "/tns:request/tns:body/Pet/name",
- "fieldType" : "STRING",
- "name" : "name",
- "userCreated" : false
- } ],
- "id" : "mapping.222691"
- } ]
- },
- "lookupTables" : {
- "lookupTable" : [ ]
- },
- "properties" : {
- "property" : [ ]
- },
- "name" : "UI.860284"
- }
-}
diff --git a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-singledoc.json b/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-singledoc.json
deleted file mode 100644
index 2175e75eedc..00000000000
--- a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-singledoc.json
+++ /dev/null
@@ -1,65 +0,0 @@
-{
- "AtlasMapping" : {
- "jsonType" : "io.atlasmap.v2.AtlasMapping",
- "dataSource" : [ {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JAVA:CONTACT:S",
- "uri" : "atlas:java?className=io.atlasmap.java.test.SourceContact",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JSON:CONTACT:S",
- "uri" : "atlas:json:JSONContact",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:XML:CONTACT:S",
- "uri" : "atlas:xml:XMLContact",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JAVA:CONTACT:T",
- "uri" : "atlas:java?className=io.atlasmap.java.test.TargetContact",
- "dataSourceType" : "TARGET"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:JSON:CONTACT:T",
- "uri" : "atlas:json:JSONContact",
- "dataSourceType" : "TARGET"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "id" : "DOCID:XML:CONTACT:T",
- "uri" : "atlas:xml:XMLContact",
- "dataSourceType" : "TARGET"
- } ],
- "mappings" : {
- "mapping" : [ {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:S",
- "path" : "/firstName",
- "fieldType" : "STRING",
- "name" : "firstName",
- "getMethod" : "getFirstName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "docId" : "DOCID:JAVA:CONTACT:T",
- "path" : "/firstName",
- "fieldType" : "STRING",
- "name" : "firstName",
- "setMethod" : "setFirstName"
- } ]
- } ]
- },
- "lookupTables" : {
- "lookupTable" : [ ]
- },
- "properties" : {
- "property" : [ ]
- },
- "name" : "mockMapping"
- }
-}
diff --git a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-xml-to-xml.json b/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-xml-to-xml.json
deleted file mode 100644
index a744e951acc..00000000000
--- a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping-xml-to-xml.json
+++ /dev/null
@@ -1,66 +0,0 @@
-{
- "AtlasMapping": {
- "dataSource": [
- {
- "dataSourceType": "SOURCE",
- "id": "-LO2lWtkzmk816-JEluS",
- "jsonType": "io.atlasmap.xml.v2.XmlDataSource",
- "uri": "atlas:xml:-LO2lWtkzmk816-JEluS",
- "xmlNamespaces": {
- "xmlNamespace": [
- {
- "alias": "tns",
- "uri": "http://hl7.org/fhir"
- }
- ]
- }
- },
- {
- "dataSourceType": "TARGET",
- "id": "-LO2lU-dzmk816-JEluS",
- "jsonType": "io.atlasmap.xml.v2.XmlDataSource",
- "uri": "atlas:xml:-LO2lU-dzmk816-JEluS",
- "xmlNamespaces": {
- "xmlNamespace": [
- {
- "alias": "tns",
- "targetNamespace": true,
- "uri": "http://hl7.org/fhir"
- }
- ]
- }
- }
- ],
- "jsonType": "io.atlasmap.v2.AtlasMapping",
- "mappings": {
- "mapping": [
- {
- "id": "mapping.431884",
- "inputField": [
- {
- "docId": "-LO2lWtkzmk816-JEluS",
- "fieldType": "STRING",
- "jsonType": "io.atlasmap.xml.v2.XmlField",
- "name": "value",
- "path": "/tns:Patient/tns:id/@value",
- "userCreated": false
- }
- ],
- "jsonType": "io.atlasmap.v2.Mapping",
- "mappingType": "MAP",
- "outputField": [
- {
- "docId": "-LO2lU-dzmk816-JEluS",
- "fieldType": "STRING",
- "jsonType": "io.atlasmap.xml.v2.XmlField",
- "name": "value",
- "path": "/tns:Patient/tns:id/@value",
- "userCreated": false
- }
- ]
- }
- ]
- },
- "name": "UI.266964"
- }
-}
diff --git a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping.json b/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping.json
deleted file mode 100644
index d938e0c9e96..00000000000
--- a/components/camel-atlasmap/src/test/resources/atlasmapping-json/atlasmapping.json
+++ /dev/null
@@ -1,95 +0,0 @@
-{
- "AtlasMapping" : {
- "jsonType" : "io.atlasmap.v2.AtlasMapping",
- "dataSource" : [ {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "uri" : "atlas:java?className=twitter4j.Status",
- "dataSourceType" : "SOURCE"
- }, {
- "jsonType" : "io.atlasmap.v2.DataSource",
- "uri" : "atlas:json:JSONContact",
- "dataSourceType" : "TARGET"
- } ],
- "mappings" : {
- "mapping" : [ {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "SEPARATE",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "path" : "/User/name",
- "fieldType" : "STRING",
- "name" : "Name",
- "getMethod" : "getName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "index" : 0,
- "path" : "/FirstName",
- "fieldType" : "STRING",
- "name" : "FirstName"
- }, {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "index" : 1,
- "path" : "/LastName",
- "fieldType" : "STRING",
- "name" : "LastName"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "path" : "/Text",
- "fieldType" : "STRING",
- "name" : "Text",
- "getMethod" : "getText"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "path" : "/Description",
- "fieldType" : "STRING",
- "name" : "Description"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.java.v2.JavaField",
- "path" : "/User/screenName",
- "fieldType" : "STRING",
- "name" : "ScreenName",
- "getMethod" : "getScreenName"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "path" : "/Title",
- "fieldType" : "STRING",
- "name" : "Title"
- } ]
- }, {
- "jsonType" : "io.atlasmap.v2.Mapping",
- "mappingType" : "MAP",
- "inputField" : [ {
- "jsonType" : "io.atlasmap.v2.ConstantField",
- "value" : "const foobar",
- "docId" : "DOC.Constants.973849",
- "path" : "/foobar",
- "fieldType" : "STRING"
- } ],
- "outputField" : [ {
- "jsonType" : "io.atlasmap.json.v2.JsonField",
- "path" : "/Constant",
- "fieldType" : "STRING",
- "name" : "Constant"
- } ]
- } ]
- },
- "lookupTables" : {
- "lookupTable" : [ ]
- },
- "properties" : {
- "property" : [ ]
- },
- "name" : "mockMapping"
- }
-}
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapExtractMappingsTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapExtractMappingsTest-context.xml
deleted file mode 100644
index 026368c69a0..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapExtractMappingsTest-context.xml
+++ /dev/null
@@ -1,39 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:adm/atlasmap-mapping.adm" />
- <to uri="mock:result" />
- </route>
- <route>
- <from uri="direct:start-n" />
- <to uri="atlasmap:adm/atlasmap-mapping-n.adm" />
- <to uri="mock:result-n" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapForceReloadTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapForceReloadTest-context.xml
deleted file mode 100644
index a917ca0ed8a..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapForceReloadTest-context.xml
+++ /dev/null
@@ -1,39 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmap-mapping-force-reload.adm" />
- <to uri="mock:result" />
- </route>
- <route>
- <from uri="direct:start-force-reload" />
- <to uri="atlasmap:atlasmap-mapping-force-reload.adm?forceReload=true" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapJavaToJsonTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapJavaToJsonTest-context.xml
deleted file mode 100644
index f3c4a9476b9..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapJavaToJsonTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-java-to-json.json" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonTest-context.xml
deleted file mode 100644
index bbb860e3a8a..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping.json" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonToJavaTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonToJavaTest-context.xml
deleted file mode 100644
index 2f1271b6d8d..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonToJavaTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-json-to-java.json" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonToXmlSchemaTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonToXmlSchemaTest-context.xml
deleted file mode 100644
index 528fed626da..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapJsonToXmlSchemaTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:adm/json-schema-source-to-xml-schema-target.adm" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapMultiDocsTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapMultiDocsTest-context.xml
deleted file mode 100644
index eab04e76336..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapMultiDocsTest-context.xml
+++ /dev/null
@@ -1,49 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-multidocs.json?sourceMapName=CAPTURED_OUT_MESSAGES_MAP&targetMapName=TARGET_MESSAGES_MAP" />
- <to uri="mock:result" />
- </route>
- <route>
- <from uri="direct:start-body" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-multidocs.json" />
- <to uri="mock:result-body" />
- </route>
- <route>
- <from uri="direct:start-header" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-multidocs.json?targetMapMode=MESSAGE_HEADER" />
- <to uri="mock:result-body" />
- </route>
- <route>
- <from uri="direct:start-exchange-property" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-multidocs.json?targetMapMode=EXCHANGE_PROPERTY" />
- <to uri="mock:result-body" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapMultiNSTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapMultiNSTest-context.xml
deleted file mode 100644
index 198d54df2e8..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapMultiNSTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-multins.json" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapSingleDocTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapSingleDocTest-context.xml
deleted file mode 100644
index ea7ab94436e..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapSingleDocTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-singledoc.json" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapTest-context.xml
deleted file mode 100644
index bbb860e3a8a..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping.json" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/context/AtlasMapXmlToXmlTest-context.xml b/components/camel-atlasmap/src/test/resources/context/AtlasMapXmlToXmlTest-context.xml
deleted file mode 100644
index 077eb24c6b3..00000000000
--- a/components/camel-atlasmap/src/test/resources/context/AtlasMapXmlToXmlTest-context.xml
+++ /dev/null
@@ -1,34 +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.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <route>
- <from uri="direct:start" />
- <to uri="atlasmap:atlasmapping-json/atlasmapping-xml-to-xml.json" />
- <to uri="mock:result" />
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-atlasmap/src/test/resources/json-source.json b/components/camel-atlasmap/src/test/resources/json-source.json
deleted file mode 100644
index 40e76ede49a..00000000000
--- a/components/camel-atlasmap/src/test/resources/json-source.json
+++ /dev/null
@@ -1,47 +0,0 @@
-{
- "order": {
- "address": {
- "street": "123 any st",
- "city": "Austin",
- "state": "TX",
- "zip": "78626"
- },
- "contact": {
- "firstName": "james",
- "lastName": "smith",
- "phone": "512-123-1234"
- },
- "orderId": "123"
- },
- "primitives": {
- "stringPrimitive": "some value",
- "booleanPrimitive": true,
- "numberPrimitive": 24
- },
- "addressList": [
- {
- "street": "123 any st",
- "city": "Austin",
- "state": "TX",
- "zip": "78626"
- },
- {
- "street": "123 any st",
- "city": "Austin",
- "state": "TX",
- "zip": "78626"
- },
- {
- "street": "123 any st",
- "city": "Austin",
- "state": "TX",
- "zip": "78626"
- },
- {
- "street": "123 any st",
- "city": "Austin",
- "state": "TX",
- "zip": "78626"
- }
- ]
-}
diff --git a/components/camel-atlasmap/src/test/resources/log4j2.properties b/components/camel-atlasmap/src/test/resources/log4j2.properties
deleted file mode 100644
index 21a3e486424..00000000000
--- a/components/camel-atlasmap/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-atlasmap-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/components/camel-atlasmap/src/test/resources/xml-target-schemaset.xml b/components/camel-atlasmap/src/test/resources/xml-target-schemaset.xml
deleted file mode 100644
index a9ca2e84939..00000000000
--- a/components/camel-atlasmap/src/test/resources/xml-target-schemaset.xml
+++ /dev/null
@@ -1,98 +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.
-
--->
-<d:SchemaSet xmlns:d="http://atlasmap.io/xml/schemaset/v2"
- xmlns:xsd="http://www.w3.org/2001/XMLSchema">
- <xsd:schema
- targetNamespace="http://syndesis.io/v1/swagger-connector-template/request"
- elementFormDefault="qualified">
- <xsd:element name="request">
- <xsd:complexType>
- <xsd:sequence>
- <xsd:element name="body">
- <xsd:complexType>
- <xsd:sequence>
- <xsd:element ref="Pet" />
- </xsd:sequence>
- </xsd:complexType>
- </xsd:element>
- </xsd:sequence>
- </xsd:complexType>
- </xsd:element>
- </xsd:schema>
- <d:AdditionalSchemas>
- <xsd:schema>
- <xsd:element name="Pet">
- <xsd:complexType>
- <xsd:sequence>
- <xsd:element name="id"
- type="xsd:decimal" minOccurs="0" />
- <xsd:element name="Category">
- <xsd:complexType>
- <xsd:sequence>
- <xsd:element name="id"
- type="xsd:decimal" minOccurs="0" />
- <xsd:element name="name"
- type="xsd:string" />
- </xsd:sequence>
- </xsd:complexType>
- </xsd:element>
- <xsd:element name="name"
- type="xsd:string" />
- <xsd:element name="photoUrl"
- minOccurs="0">
- <xsd:complexType>
- <xsd:sequence>
- <xsd:element
- name="photoUrl"
- type="xsd:string"
- maxOccurs="unbounded"
- minOccurs="0" />
- </xsd:sequence>
- </xsd:complexType>
- </xsd:element>
- <xsd:element name="tag"
- minOccurs="0">
- <xsd:complexType>
- <xsd:sequence>
- <xsd:element name="Tag"
- maxOccurs="unbounded"
- minOccurs="0">
- <xsd:complexType>
- <xsd:sequence>
- <xsd:element
- name="id"
- type="xsd:decimal" />
- <xsd:element
- name="name"
- type="xsd:string" />
- </xsd:sequence>
- </xsd:complexType>
- </xsd:element>
- </xsd:sequence>
- </xsd:complexType>
- </xsd:element>
- <xsd:element name="status"
- type="xsd:string" />
- </xsd:sequence>
- </xsd:complexType>
- </xsd:element>
- </xsd:schema>
- </d:AdditionalSchemas>
-</d:SchemaSet>
diff --git a/components/camel-attachments/src/test/java/org/apache/camel/attachment/MulticastAggregationStrategyTest.java b/components/camel-attachments/src/test/java/org/apache/camel/attachment/MulticastAggregationStrategyTest.java
index 85c134bc5fd..cda4c68f039 100644
--- a/components/camel-attachments/src/test/java/org/apache/camel/attachment/MulticastAggregationStrategyTest.java
+++ b/components/camel-attachments/src/test/java/org/apache/camel/attachment/MulticastAggregationStrategyTest.java
@@ -1,6 +1,23 @@
+/*
+ * 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.attachment;
import jakarta.activation.DataHandler;
+
import org.apache.camel.AggregationStrategy;
import org.apache.camel.Exchange;
import org.apache.camel.builder.Builder;
@@ -17,11 +34,11 @@ class MulticastAggregationStrategyTest extends CamelTestSupport {
@Test
void testAggregationStrategyWithAttachment() {
Exchange exchange = ExchangeBuilder.anExchange(new DefaultCamelContext()).build();
-
+
template.send("direct:start", exchange);
AttachmentMessage msg = exchange.getMessage(AttachmentMessage.class);
-
+
assertTrue(msg.hasAttachments());
}
@@ -36,14 +53,14 @@ class MulticastAggregationStrategyTest extends CamelTestSupport {
.end();
from("direct:setBody")
- .setBody(Builder.constant("body"));
+ .setBody(Builder.constant("body"));
from("direct:setAttachment")
- .setBody(Builder.constant("attachment".getBytes()));
+ .setBody(Builder.constant("attachment".getBytes()));
}
};
}
-
+
private static class AttachmentMessageAggregationStrategy implements AggregationStrategy {
@Override
@@ -56,7 +73,8 @@ class MulticastAggregationStrategyTest extends CamelTestSupport {
oldExchange.getMessage().setBody(newExchange.getIn().getBody());
} else {
byte[] data = newExchange.getIn().getBody(byte[].class);
- oldExchange.getMessage(AttachmentMessage.class).addAttachment("attachment", new DataHandler(data, "text/plain"));
+ oldExchange.getMessage(AttachmentMessage.class).addAttachment("attachment",
+ new DataHandler(data, "text/plain"));
}
return oldExchange;
diff --git a/components/pom.xml b/components/pom.xml
index 0feded22eac..ec4a9288148 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -80,7 +80,6 @@
<module>camel-as2</module>
<module>camel-asn1</module>
<module>camel-asterisk</module>
- <module>camel-atlasmap</module>
<module>camel-atmosphere-websocket</module>
<module>camel-atom</module>
<module>camel-avro</module>
diff --git a/core/camel-core-engine/src/main/docs/modules/eips/pages/content-enricher.adoc b/core/camel-core-engine/src/main/docs/modules/eips/pages/content-enricher.adoc
index 5a65a755b4a..5cb60fa2260 100644
--- a/core/camel-core-engine/src/main/docs/modules/eips/pages/content-enricher.adoc
+++ b/core/camel-core-engine/src/main/docs/modules/eips/pages/content-enricher.adoc
@@ -22,8 +22,7 @@ The most natural Camel approach is using xref:enrich-eip.adoc[Enrich] EIP.
You can consume a message from
one destination, transform it with something like
-xref:ROOT:velocity-component.adoc[Velocity], xref:ROOT:xquery-component.adoc[XQuery],
-or xref:ROOT:atlasmap-component.adoc[AtlasMap]
+xref:ROOT:velocity-component.adoc[Velocity] or xref:ROOT:xquery-component.adoc[XQuery]
and then send it on to another destination.
[tabs]
@@ -158,4 +157,4 @@ Consumer] to obtain the additional data. It is usually used for
xref:event-message.adoc[Event Message] messaging, for instance to read a
file or download a xref:ROOT:ftp-component.adoc[FTP] file.
-For more details see xref:enrich-eip.adoc[Enrich] EIP and xref:pollEnrich-eip.adoc[Poll Enrich] EIP.
\ No newline at end of file
+For more details see xref:enrich-eip.adoc[Enrich] EIP and xref:pollEnrich-eip.adoc[Poll Enrich] EIP.
diff --git a/core/camel-core-engine/src/main/docs/modules/eips/pages/messaging-mapper.adoc b/core/camel-core-engine/src/main/docs/modules/eips/pages/messaging-mapper.adoc
index 990bbf3b560..9319dc98dd4 100644
--- a/core/camel-core-engine/src/main/docs/modules/eips/pages/messaging-mapper.adoc
+++ b/core/camel-core-engine/src/main/docs/modules/eips/pages/messaging-mapper.adoc
@@ -21,5 +21,3 @@ xref:manual::type-converter.adoc[Type Converter]'s from the messaging infrastruc
Java Objects representing the data model of the component in question. Combining this with the
xref:message-translator.adoc[Message Translator] to have the Messaging Mapper EIP pattern.
-Camel also integrates with external mapping software such as xref:ROOT:atlasmap-component.adoc[AtlasMap].
-
diff --git a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
index df192153050..d7ffb452357 100644
--- a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
+++ b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
@@ -3,7 +3,6 @@ amqp
arangodb
as2
asterisk
-atlasmap
atmosphere-websocket
atom
avro
diff --git a/core/camel-support/src/main/java/org/apache/camel/support/ExchangeHelper.java b/core/camel-support/src/main/java/org/apache/camel/support/ExchangeHelper.java
index 3841061f1de..f62e8de0403 100644
--- a/core/camel-support/src/main/java/org/apache/camel/support/ExchangeHelper.java
+++ b/core/camel-support/src/main/java/org/apache/camel/support/ExchangeHelper.java
@@ -46,7 +46,6 @@ import org.apache.camel.NoSuchPropertyException;
import org.apache.camel.NoTypeConversionAvailableException;
import org.apache.camel.Route;
import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.SafeCopyProperty;
import org.apache.camel.TypeConversionException;
import org.apache.camel.WrappedFile;
import org.apache.camel.spi.NormalizedEndpointUri;
diff --git a/docs/components/modules/ROOT/examples/json/atlasmap.json b/docs/components/modules/ROOT/examples/json/atlasmap.json
deleted file mode 120000
index 93646df0183..00000000000
--- a/docs/components/modules/ROOT/examples/json/atlasmap.json
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../../components/camel-atlasmap/src/generated/resources/org/apache/camel/component/atlasmap/atlasmap.json
\ No newline at end of file
diff --git a/docs/components/modules/ROOT/nav.adoc b/docs/components/modules/ROOT/nav.adoc
index b70bb75b47e..cefb086c1f0 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -7,7 +7,6 @@
** xref:arangodb-component.adoc[ArangoDb]
** xref:as2-component.adoc[AS2]
** xref:asterisk-component.adoc[Asterisk]
-** xref:atlasmap-component.adoc[AtlasMap]
** xref:atmosphere-websocket-component.adoc[Atmosphere Websocket]
** xref:atom-component.adoc[Atom]
** xref:avro-component.adoc[Avro RPC]
diff --git a/docs/components/modules/ROOT/pages/atlasmap-component.adoc b/docs/components/modules/ROOT/pages/atlasmap-component.adoc
deleted file mode 120000
index 372e4215f24..00000000000
--- a/docs/components/modules/ROOT/pages/atlasmap-component.adoc
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../components/camel-atlasmap/src/main/docs/atlasmap-component.adoc
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index 3ca6a29196d..c9473e48dd5 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -110,19 +110,6 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.AsteriskComponentBuilderFactory.AsteriskComponentBuilder asterisk() {
return org.apache.camel.builder.component.dsl.AsteriskComponentBuilderFactory.asterisk();
}
- /**
- * AtlasMap (camel-atlasmap)
- * Transforms the message using an AtlasMap transformation.
- *
- * Category: transformation
- * Since: 3.7
- * Maven coordinates: org.apache.camel:camel-atlasmap
- *
- * @return the dsl builder
- */
- static org.apache.camel.builder.component.dsl.AtlasmapComponentBuilderFactory.AtlasmapComponentBuilder atlasmap() {
- return org.apache.camel.builder.component.dsl.AtlasmapComponentBuilderFactory.atlasmap();
- }
/**
* Atmosphere Websocket (camel-atmosphere-websocket)
* Expose WebSocket endpoints using the Atmosphere framework.
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AtlasmapComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AtlasmapComponentBuilderFactory.java
deleted file mode 100644
index 71a5fafc4aa..00000000000
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AtlasmapComponentBuilderFactory.java
+++ /dev/null
@@ -1,155 +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.builder.component.dsl;
-
-import javax.annotation.processing.Generated;
-import org.apache.camel.Component;
-import org.apache.camel.builder.component.AbstractComponentBuilder;
-import org.apache.camel.builder.component.ComponentBuilder;
-import org.apache.camel.component.atlasmap.AtlasMapComponent;
-
-/**
- * Transforms the message using an AtlasMap transformation.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface AtlasmapComponentBuilderFactory {
-
- /**
- * AtlasMap (camel-atlasmap)
- * Transforms the message using an AtlasMap transformation.
- *
- * Category: transformation
- * Since: 3.7
- * Maven coordinates: org.apache.camel:camel-atlasmap
- *
- * @return the dsl builder
- */
- static AtlasmapComponentBuilder atlasmap() {
- return new AtlasmapComponentBuilderImpl();
- }
-
- /**
- * Builder for the AtlasMap component.
- */
- interface AtlasmapComponentBuilder
- extends
- ComponentBuilder<AtlasMapComponent> {
- /**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes to
- * startup in situations where a producer may otherwise fail during
- * starting and cause the route to fail being started. By deferring this
- * startup to be lazy then the startup failure can be handled during
- * routing messages via Camel's routing error handlers. Beware that when
- * the first message is processed then creating and starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default AtlasmapComponentBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * To use the AtlasContextFactory otherwise a new engine is created.
- *
- * The option is a:
- * <code>io.atlasmap.api.AtlasContextFactory</code> type.
- *
- * Group: advanced
- *
- * @param atlasContextFactory the value to set
- * @return the dsl builder
- */
- default AtlasmapComponentBuilder atlasContextFactory(
- io.atlasmap.api.AtlasContextFactory atlasContextFactory) {
- doSetProperty("atlasContextFactory", atlasContextFactory);
- return this;
- }
- /**
- * Whether autowiring is enabled. This is used for automatic autowiring
- * options (the option must be marked as autowired) by looking up in the
- * registry to find if there is a single instance of matching type,
- * which then gets configured on the component. This can be used for
- * automatic configuring JDBC data sources, JMS connection factories,
- * AWS Clients, etc.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: advanced
- *
- * @param autowiredEnabled the value to set
- * @return the dsl builder
- */
- default AtlasmapComponentBuilder autowiredEnabled(
- boolean autowiredEnabled) {
- doSetProperty("autowiredEnabled", autowiredEnabled);
- return this;
- }
- /**
- * The URI of the properties file which is used for AtlasContextFactory
- * initialization.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: advanced
- *
- * @param propertiesFile the value to set
- * @return the dsl builder
- */
- default AtlasmapComponentBuilder propertiesFile(
- java.lang.String propertiesFile) {
- doSetProperty("propertiesFile", propertiesFile);
- return this;
- }
- }
-
- class AtlasmapComponentBuilderImpl
- extends
- AbstractComponentBuilder<AtlasMapComponent>
- implements
- AtlasmapComponentBuilder {
- @Override
- protected AtlasMapComponent buildConcreteComponent() {
- return new AtlasMapComponent();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "lazyStartProducer": ((AtlasMapComponent) component).setLazyStartProducer((boolean) value); return true;
- case "atlasContextFactory": ((AtlasMapComponent) component).setAtlasContextFactory((io.atlasmap.api.AtlasContextFactory) value); return true;
- case "autowiredEnabled": ((AtlasMapComponent) component).setAutowiredEnabled((boolean) value); return true;
- case "propertiesFile": ((AtlasMapComponent) component).setPropertiesFile((java.lang.String) value); return true;
- default: return false;
- }
- }
- }
-}
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/resources/metadata.json b/dsl/camel-componentdsl/src/generated/resources/metadata.json
index 1718efe42ae..9406f52dbb9 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -111,28 +111,6 @@
"producerOnly": false,
"lenientProperties": false
},
- "AtlasmapComponentBuilderFactory": {
- "kind": "component",
- "name": "atlasmap",
- "title": "AtlasMap",
- "description": "Transforms the message using an AtlasMap transformation.",
- "deprecated": false,
- "firstVersion": "3.7.0",
- "label": "transformation",
- "javaType": "org.apache.camel.component.atlasmap.AtlasMapComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-atlasmap",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "atlasmap",
- "extendsScheme": "",
- "syntax": "atlasmap:resourceUri",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": true,
- "lenientProperties": false
- },
"AtmosphereWebsocketComponentBuilderFactory": {
"kind": "component",
"name": "atmosphere-websocket",
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index c281b59a419..cf13b4f992e 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -35,7 +35,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.ArangoDbEndpointBuilderFactory.ArangoDbBuilders,
org.apache.camel.builder.endpoint.dsl.AsteriskEndpointBuilderFactory.AsteriskBuilders,
org.apache.camel.builder.endpoint.dsl.Athena2EndpointBuilderFactory.Athena2Builders,
- org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory.AtlasMapBuilders,
org.apache.camel.builder.endpoint.dsl.AtmosphereWebsocketEndpointBuilderFactory.AtmosphereWebsocketBuilders,
org.apache.camel.builder.endpoint.dsl.AtomEndpointBuilderFactory.AtomBuilders,
org.apache.camel.builder.endpoint.dsl.AvroEndpointBuilderFactory.AvroBuilders,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index 3f9a00b3a39..f8aeb2d08c6 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -32,7 +32,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.ArangoDbEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AsteriskEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.Athena2EndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AtmosphereWebsocketEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AtomEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.AvroEndpointBuilderFactory,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index cffa7de6fc5..dc41d87267e 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -275,61 +275,6 @@ public class StaticEndpointBuilders {
String path) {
return org.apache.camel.builder.endpoint.dsl.AsteriskEndpointBuilderFactory.endpointBuilder(componentName, path);
}
- /**
- * AtlasMap (camel-atlasmap)
- * Transforms the message using an AtlasMap transformation.
- *
- * Category: transformation
- * Since: 3.7
- * Maven coordinates: org.apache.camel:camel-atlasmap
- *
- * Syntax: <code>atlasmap:resourceUri</code>
- *
- * Path parameter: resourceUri (required)
- * Path to the resource. You can prefix with: classpath, file, http, ref, or
- * bean. classpath, file and http loads the resource using these protocols
- * (classpath is default). ref will lookup the resource in the registry.
- * bean will call a method on a bean to be used as the resource. For bean
- * you can specify the method name after dot, eg bean:myBean.myMethod.
- * This option can also be loaded from an existing file, by prefixing with
- * file: or classpath: followed by the location of the file.
- *
- * @param path resourceUri
- * @return the dsl builder
- */
- public static org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory.AtlasMapEndpointBuilder atlasmap(
- String path) {
- return org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory.endpointBuilder("atlasmap", path);
- }
- /**
- * AtlasMap (camel-atlasmap)
- * Transforms the message using an AtlasMap transformation.
- *
- * Category: transformation
- * Since: 3.7
- * Maven coordinates: org.apache.camel:camel-atlasmap
- *
- * Syntax: <code>atlasmap:resourceUri</code>
- *
- * Path parameter: resourceUri (required)
- * Path to the resource. You can prefix with: classpath, file, http, ref, or
- * bean. classpath, file and http loads the resource using these protocols
- * (classpath is default). ref will lookup the resource in the registry.
- * bean will call a method on a bean to be used as the resource. For bean
- * you can specify the method name after dot, eg bean:myBean.myMethod.
- * This option can also be loaded from an existing file, by prefixing with
- * file: or classpath: followed by the location of the file.
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path resourceUri
- * @return the dsl builder
- */
- public static org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory.AtlasMapEndpointBuilder atlasmap(
- String componentName,
- String path) {
- return org.apache.camel.builder.endpoint.dsl.AtlasMapEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
/**
* Atmosphere Websocket (camel-atmosphere-websocket)
* Expose WebSocket endpoints using the Atmosphere framework.
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AtlasMapEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AtlasMapEndpointBuilderFactory.java
deleted file mode 100644
index 31ed14cf628..00000000000
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AtlasMapEndpointBuilderFactory.java
+++ /dev/null
@@ -1,427 +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.builder.endpoint.dsl;
-
-import java.util.*;
-import java.util.concurrent.*;
-import java.util.function.*;
-import java.util.stream.*;
-import javax.annotation.processing.Generated;
-import org.apache.camel.builder.EndpointConsumerBuilder;
-import org.apache.camel.builder.EndpointProducerBuilder;
-import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
-
-/**
- * Transforms the message using an AtlasMap transformation.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface AtlasMapEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint for the AtlasMap component.
- */
- public interface AtlasMapEndpointBuilder extends EndpointProducerBuilder {
- default AdvancedAtlasMapEndpointBuilder advanced() {
- return (AdvancedAtlasMapEndpointBuilder) this;
- }
- /**
- * Sets whether the context map should allow access to all details. By
- * default only the message body and headers can be accessed. This
- * option can be enabled for full access to the current Exchange and
- * CamelContext. Doing so impose a potential security risk as this opens
- * access to the full power of CamelContext API.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param allowContextMapAll the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder allowContextMapAll(
- boolean allowContextMapAll) {
- doSetProperty("allowContextMapAll", allowContextMapAll);
- return this;
- }
- /**
- * Sets whether the context map should allow access to all details. By
- * default only the message body and headers can be accessed. This
- * option can be enabled for full access to the current Exchange and
- * CamelContext. Doing so impose a potential security risk as this opens
- * access to the full power of CamelContext API.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: producer
- *
- * @param allowContextMapAll the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder allowContextMapAll(
- String allowContextMapAll) {
- doSetProperty("allowContextMapAll", allowContextMapAll);
- return this;
- }
- /**
- * Sets whether to use resource content cache or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param contentCache the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder contentCache(boolean contentCache) {
- doSetProperty("contentCache", contentCache);
- return this;
- }
- /**
- * Sets whether to use resource content cache or not.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: producer
- *
- * @param contentCache the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder contentCache(String contentCache) {
- doSetProperty("contentCache", contentCache);
- return this;
- }
- /**
- * Whether to enable or disable force reload mode. This is set to false
- * by default and ADM file is loaded from a file only on a first
- * Exchange, and AtlasContext will be reused after that until endpoint
- * is recreated. If this is set to true, ADM file will be loaded from a
- * file on every Exchange.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param forceReload the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder forceReload(boolean forceReload) {
- doSetProperty("forceReload", forceReload);
- return this;
- }
- /**
- * Whether to enable or disable force reload mode. This is set to false
- * by default and ADM file is loaded from a file only on a first
- * Exchange, and AtlasContext will be reused after that until endpoint
- * is recreated. If this is set to true, ADM file will be loaded from a
- * file on every Exchange.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: producer
- *
- * @param forceReload the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder forceReload(String forceReload) {
- doSetProperty("forceReload", forceReload);
- return this;
- }
- /**
- * The Exchange property name for a source message map which hold
- * java.util.Map&amp;lt;String, Message&amp;gt; where the key is
- * AtlasMap Document ID. AtlasMap consumes Message bodies as source
- * documents, as well as message headers as source properties where the
- * scope equals to Document ID.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param sourceMapName the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder sourceMapName(String sourceMapName) {
- doSetProperty("sourceMapName", sourceMapName);
- return this;
- }
- /**
- * TargetMapMode enum value to specify how multiple target documents are
- * delivered if exist. 'MAP': Stores them into a java.util.Map, and the
- * java.util.Map is set to an exchange property if 'targetMapName' is
- * specified, otherwise message body. 'MESSAGE_HEADER': Stores them into
- * message headers. 'EXCHANGE_PROPERTY': Stores them into exchange
- * properties. ).
- *
- * The option is a:
- * <code>org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode</code> type.
- *
- * Default: MAP
- * Group: producer
- *
- * @param targetMapMode the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder targetMapMode(
- org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode targetMapMode) {
- doSetProperty("targetMapMode", targetMapMode);
- return this;
- }
- /**
- * TargetMapMode enum value to specify how multiple target documents are
- * delivered if exist. 'MAP': Stores them into a java.util.Map, and the
- * java.util.Map is set to an exchange property if 'targetMapName' is
- * specified, otherwise message body. 'MESSAGE_HEADER': Stores them into
- * message headers. 'EXCHANGE_PROPERTY': Stores them into exchange
- * properties. ).
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.atlasmap.AtlasMapEndpoint.TargetMapMode</code> type.
- *
- * Default: MAP
- * Group: producer
- *
- * @param targetMapMode the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder targetMapMode(String targetMapMode) {
- doSetProperty("targetMapMode", targetMapMode);
- return this;
- }
- /**
- * The Exchange property name for a target document map which hold
- * java.util.Map&amp;lt;String, Object&amp;gt; where the key is
- * AtlasMap Document ID. AtlasMap populates multiple target documents
- * into this map.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param targetMapName the value to set
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder targetMapName(String targetMapName) {
- doSetProperty("targetMapName", targetMapName);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the AtlasMap component.
- */
- public interface AdvancedAtlasMapEndpointBuilder
- extends
- EndpointProducerBuilder {
- default AtlasMapEndpointBuilder basic() {
- return (AtlasMapEndpointBuilder) this;
- }
- /**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes to
- * startup in situations where a producer may otherwise fail during
- * starting and cause the route to fail being started. By deferring this
- * startup to be lazy then the startup failure can be handled during
- * routing messages via Camel's routing error handlers. Beware that when
- * the first message is processed then creating and starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer (advanced)
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default AdvancedAtlasMapEndpointBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes to
- * startup in situations where a producer may otherwise fail during
- * starting and cause the route to fail being started. By deferring this
- * startup to be lazy then the startup failure can be handled during
- * routing messages via Camel's routing error handlers. Beware that when
- * the first message is processed then creating and starting the
- * producer may take a little time and prolong the total processing time
- * of the processing.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: producer (advanced)
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default AdvancedAtlasMapEndpointBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- }
-
- public interface AtlasMapBuilders {
- /**
- * AtlasMap (camel-atlasmap)
- * Transforms the message using an AtlasMap transformation.
- *
- * Category: transformation
- * Since: 3.7
- * Maven coordinates: org.apache.camel:camel-atlasmap
- *
- * @return the dsl builder for the headers' name.
- */
- default AtlasMapHeaderNameBuilder atlasmap() {
- return AtlasMapHeaderNameBuilder.INSTANCE;
- }
- /**
- * AtlasMap (camel-atlasmap)
- * Transforms the message using an AtlasMap transformation.
- *
- * Category: transformation
- * Since: 3.7
- * Maven coordinates: org.apache.camel:camel-atlasmap
- *
- * Syntax: <code>atlasmap:resourceUri</code>
- *
- * Path parameter: resourceUri (required)
- * Path to the resource. You can prefix with: classpath, file, http,
- * ref, or bean. classpath, file and http loads the resource using these
- * protocols (classpath is default). ref will lookup the resource in the
- * registry. bean will call a method on a bean to be used as the
- * resource. For bean you can specify the method name after dot, eg
- * bean:myBean.myMethod.
- * This option can also be loaded from an existing file, by prefixing
- * with file: or classpath: followed by the location of the file.
- *
- * @param path resourceUri
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder atlasmap(String path) {
- return AtlasMapEndpointBuilderFactory.endpointBuilder("atlasmap", path);
- }
- /**
- * AtlasMap (camel-atlasmap)
- * Transforms the message using an AtlasMap transformation.
- *
- * Category: transformation
- * Since: 3.7
- * Maven coordinates: org.apache.camel:camel-atlasmap
- *
- * Syntax: <code>atlasmap:resourceUri</code>
- *
- * Path parameter: resourceUri (required)
- * Path to the resource. You can prefix with: classpath, file, http,
- * ref, or bean. classpath, file and http loads the resource using these
- * protocols (classpath is default). ref will lookup the resource in the
- * registry. bean will call a method on a bean to be used as the
- * resource. For bean you can specify the method name after dot, eg
- * bean:myBean.myMethod.
- * This option can also be loaded from an existing file, by prefixing
- * with file: or classpath: followed by the location of the file.
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path resourceUri
- * @return the dsl builder
- */
- default AtlasMapEndpointBuilder atlasmap(
- String componentName,
- String path) {
- return AtlasMapEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
-
- /**
- * The builder of headers' name for the AtlasMap component.
- */
- public static class AtlasMapHeaderNameBuilder {
- /**
- * The internal instance of the builder used to access to all the
- * methods representing the name of headers.
- */
- private static final AtlasMapHeaderNameBuilder INSTANCE = new AtlasMapHeaderNameBuilder();
-
- /**
- * The new resource URI to use.
- *
- * The option is a: {@code java.lang.String} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code AtlasResourceUri}.
- */
- public String atlasResourceUri() {
- return "AtlasResourceUri";
- }
-
- /**
- * The Atlas mapping to use.
- *
- * The option is a: {@code java.lang.String} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code AtlasMapping}.
- */
- public String atlasMapping() {
- return "AtlasMapping";
- }
-
- /**
- * The content type that is set according to the datasource (json or
- * xml).
- *
- * The option is a: {@code java.lang.String} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code Content-Type}.
- */
- public String contentType() {
- return "Content-Type";
- }
- }
- static AtlasMapEndpointBuilder endpointBuilder(
- String componentName,
- String path) {
- class AtlasMapEndpointBuilderImpl extends AbstractEndpointBuilder implements AtlasMapEndpointBuilder, AdvancedAtlasMapEndpointBuilder {
- public AtlasMapEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new AtlasMapEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file
diff --git a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
index 8f92737ce8e..d473d9e0d16 100644
--- a/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
+++ b/dsl/camel-kamelet-main/src/generated/resources/camel-component-known-dependencies.properties
@@ -22,7 +22,6 @@ org.apache.camel.component.amqp.AMQPComponent=camel:amqp
org.apache.camel.component.arangodb.ArangoDbComponent=camel:arangodb
org.apache.camel.component.as2.AS2Component=camel:as2
org.apache.camel.component.asterisk.AsteriskComponent=camel:asterisk
-org.apache.camel.component.atlasmap.AtlasMapComponent=camel:atlasmap
org.apache.camel.component.atmosphere.websocket.WebsocketComponent=camel:atmosphere-websocket
org.apache.camel.component.atom.AtomComponent=camel:atom
org.apache.camel.component.avro.AvroComponent=camel:avro-rpc
diff --git a/parent/pom.xml b/parent/pom.xml
index de30017713d..8587bc63f66 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -62,7 +62,6 @@
<asn1bean-version>1.14.0</asn1bean-version>
<assertj-version>3.24.2</assertj-version>
<asterisk-java-version>3.39.0</asterisk-java-version>
- <atlasmap-version>2.5.2</atlasmap-version>
<atlassian-fugue-version>5.0.0</atlassian-fugue-version>
<atmosphere-version>3.0.3</atmosphere-version>
<avro-version>1.11.2</avro-version>
@@ -679,11 +678,6 @@
<artifactId>camel-asterisk</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-atlasmap</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-atmosphere-websocket</artifactId>