You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/01/12 14:52:15 UTC
[camel] branch main updated: CAMEL-18905: Remove camel-gora in v4
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 7f6d5c2f3f0 CAMEL-18905: Remove camel-gora in v4
7f6d5c2f3f0 is described below
commit 7f6d5c2f3f074e9b2edae7a0601642823512b390
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Jan 12 15:51:58 2023 +0100
CAMEL-18905: Remove camel-gora in v4
---
bom/camel-bom/pom.xml | 5 -
camel-dependencies/pom.xml | 1 -
catalog/camel-allcomponents/pom.xml | 5 -
.../org/apache/camel/catalog/components.properties | 1 -
.../org/apache/camel/catalog/components/gora.json | 57 --
components/camel-gora/pom.xml | 143 ---
.../component/gora/GoraComponentConfigurer.java | 61 --
.../component/gora/GoraEndpointConfigurer.java | 160 ----
.../component/gora/GoraEndpointUriFactory.java | 89 --
.../services/org/apache/camel/component.properties | 7 -
.../services/org/apache/camel/component/gora | 2 -
.../org/apache/camel/configurer/gora-component | 2 -
.../org/apache/camel/configurer/gora-endpoint | 2 -
.../org/apache/camel/urifactory/gora-endpoint | 2 -
.../org/apache/camel/component/gora/gora.json | 57 --
.../camel-gora/src/main/docs/gora-component.adoc | 222 -----
.../apache/camel/component/gora/GoraAttribute.java | 108 ---
.../apache/camel/component/gora/GoraComponent.java | 106 ---
.../camel/component/gora/GoraConfiguration.java | 286 ------
.../apache/camel/component/gora/GoraConstants.java | 36 -
.../apache/camel/component/gora/GoraConsumer.java | 95 --
.../apache/camel/component/gora/GoraEndpoint.java | 80 --
.../apache/camel/component/gora/GoraOperation.java | 80 --
.../apache/camel/component/gora/GoraProducer.java | 110 ---
.../camel/component/gora/utils/GoraUtils.java | 248 ------
.../component/gora/GoraConfigurationTest.java | 77 --
.../camel/component/gora/GoraProducerTest.java | 235 -----
.../camel/component/gora/GoraTestSupport.java | 28 -
.../camel/component/gora/utils/GoraUtilsTest.java | 51 --
.../src/test/resources/log4j2.properties | 28 -
components/pom.xml | 1 -
.../org/apache/camel/main/components.properties | 1 -
.../modules/ROOT/examples/json/gora.json | 1 -
docs/components/modules/ROOT/nav.adoc | 1 -
.../modules/ROOT/pages/gora-component.adoc | 1 -
.../ROOT/pages/camel-4-migration-guide.adoc | 1 +
.../component/ComponentsBuilderFactory.java | 13 -
.../component/dsl/GoraComponentBuilderFactory.java | 140 ---
.../src/generated/resources/metadata.json | 22 -
.../builder/endpoint/EndpointBuilderFactory.java | 1 -
.../camel/builder/endpoint/EndpointBuilders.java | 1 -
.../builder/endpoint/StaticEndpointBuilders.java | 43 -
.../endpoint/dsl/GoraEndpointBuilderFactory.java | 971 ---------------------
.../camel-component-known-dependencies.properties | 1 -
parent/pom.xml | 6 -
45 files changed, 1 insertion(+), 3587 deletions(-)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 1fa5d647be1..620cf555b39 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -826,11 +826,6 @@
<artifactId>camel-google-storage</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-gora</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-grape</artifactId>
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index 112e0968b04..0b72dd203c3 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -60,7 +60,6 @@
<apacheds-version>2.0.0.AM26</apacheds-version>
<apache-any23-version>2.7</apache-any23-version>
<apache-drill-version>1.19.0</apache-drill-version>
- <apache-gora-version>0.9</apache-gora-version>
<apicurio-version>1.1.26</apicurio-version>
<arangodb-java-version>6.20.0</arangodb-java-version>
<aries-blueprint-api-version>1.0.1</aries-blueprint-api-version>
diff --git a/catalog/camel-allcomponents/pom.xml b/catalog/camel-allcomponents/pom.xml
index f8531499ed0..636385c6cad 100644
--- a/catalog/camel-allcomponents/pom.xml
+++ b/catalog/camel-allcomponents/pom.xml
@@ -683,11 +683,6 @@
<artifactId>camel-google-storage</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-gora</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-grape</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 3266d2f1150..3fadd2962d3 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
@@ -115,7 +115,6 @@ google-secret-manager
google-sheets
google-sheets-stream
google-storage
-gora
grape
graphql
grpc
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/gora.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/gora.json
deleted file mode 100644
index c7ffda5919a..00000000000
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/gora.json
+++ /dev/null
@@ -1,57 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "gora",
- "title": "Gora",
- "description": "Access NoSQL databases using the Apache Gora framework.",
- "deprecated": false,
- "firstVersion": "2.14.0",
- "label": "database,nosql,bigdata",
- "javaType": "org.apache.camel.component.gora.GoraComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-gora",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "gora",
- "extendsScheme": "",
- "syntax": "gora:name",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
- "componentProperties": {
- "bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a me [...]
- "lazyStartProducer": { "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 during star [...]
- "autowiredEnabled": { "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 type, which t [...]
- },
- "headers": {
- "goraKey": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Object", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Used in order to define the datum key for the operations need it.", "constantName": "org.apache.camel.component.gora.GoraAttribute#GORA_KEY@value" },
- "goraOperation": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Used in order to define the operation to execute.", "constantName": "org.apache.camel.component.gora.GoraAttribute#GORA_OPERATION@value" }
- },
- "properties": {
- "name": { "kind": "path", "displayName": "Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Instance name" },
- "dataStoreClass": { "kind": "parameter", "displayName": "Data Store Class", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The type of the dataStore" },
- "keyClass": { "kind": "parameter", "displayName": "Key Class", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The type class of the key" },
- "valueClass": { "kind": "parameter", "displayName": "Value Class", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The type of the value" },
- "concurrentConsumers": { "kind": "parameter", "displayName": "Concurrent Consumers", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Number of concurrent consumers" },
- "endKey": { "kind": "parameter", "displayName": "End Key", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The End Key" },
- "endTime": { "kind": "parameter", "displayName": "End Time", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The End Time" },
- "fields": { "kind": "parameter", "displayName": "Fields", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "com.google.common.base.Strings", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Fields" },
- "keyRangeFrom": { "kind": "parameter", "displayName": "Key Range From", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Key Range From" },
- "keyRangeTo": { "kind": "parameter", "displayName": "Key Range To", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Key Range To" },
- "limit": { "kind": "parameter", "displayName": "Limit", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Limit" },
- "startKey": { "kind": "parameter", "displayName": "Start Key", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Start Key" },
- "startTime": { "kind": "parameter", "displayName": "Start Time", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Start Time" },
- "timeRangeFrom": { "kind": "parameter", "displayName": "Time Range From", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Time Range From" },
- "timeRangeTo": { "kind": "parameter", "displayName": "Time Range To", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Time Range To" },
- "timestamp": { "kind": "parameter", "displayName": "Timestamp", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Timestamp" },
- "bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now [...]
- "exceptionHandler": { "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the con [...]
- "exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "flushOnEveryOperation": { "kind": "parameter", "displayName": "Flush On Every Operation", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Flush on every operation" },
- "lazyStartProducer": { "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 producer may other [...]
- "hadoopConfiguration": { "kind": "parameter", "displayName": "Hadoop Configuration", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.hadoop.conf.Configuration", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Hadoop Configuration" }
- }
-}
diff --git a/components/camel-gora/pom.xml b/components/camel-gora/pom.xml
deleted file mode 100644
index 364c402b900..00000000000
--- a/components/camel-gora/pom.xml
+++ /dev/null
@@ -1,143 +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-gora</artifactId>
- <packaging>jar</packaging>
- <name>Camel :: Gora</name>
- <description>Gora Component for Apache Camel</description>
-
- <properties>
- </properties>
-
- <dependencies>
- <!-- logging -->
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-slf4j-impl</artifactId>
- <scope>test</scope>
- </dependency>
-
- <!-- testing -->
- <dependency>
- <groupId>org.junit.jupiter</groupId>
- <artifactId>junit-jupiter</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-junit-jupiter</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-junit5</artifactId>
- <scope>test</scope>
- </dependency>
-
- <!-- apache camel -->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-support</artifactId>
- </dependency>
-
- <!-- apache gora -->
- <dependency>
- <groupId>org.apache.hadoop</groupId>
- <artifactId>hadoop-common</artifactId>
- <version>3.2.4</version>
- </dependency>
- <dependency>
- <groupId>org.apache.gora</groupId>
- <artifactId>gora-core</artifactId>
- <version>${apache-gora-version}</version>
- <exclusions>
- <exclusion>
- <groupId>org.slf4j</groupId>
- <artifactId>slf4j-log4j12</artifactId>
- </exclusion>
- <exclusion>
- <groupId>log4j</groupId>
- <artifactId>log4j</artifactId>
- </exclusion>
- <exclusion>
- <groupId>com.google.guava</groupId>
- <artifactId>guava</artifactId>
- </exclusion>
- <exclusion>
- <groupId>com.google.code.findbugs</groupId>
- <artifactId>jsr305</artifactId>
- </exclusion>
- </exclusions>
- </dependency>
- <dependency>
- <groupId>com.google.guava</groupId>
- <artifactId>guava</artifactId>
- <version>${guava-eventbus-version}</version>
- </dependency>
-
- <!-- Avro -->
- <dependency>
- <groupId>org.apache.avro</groupId>
- <artifactId>avro</artifactId>
- <version>${avro-version}</version>
- </dependency>
-
- <!-- other -->
- <!-- Avro needs this version of jackson -->
- <dependency>
- <groupId>org.codehaus.jackson</groupId>
- <artifactId>jackson-core-asl</artifactId>
- <version>${jackson-version}</version>
- </dependency>
- <dependency>
- <groupId>org.codehaus.jackson</groupId>
- <artifactId>jackson-mapper-asl</artifactId>
- <version>${jackson-version}</version>
- </dependency>
- <dependency>
- <groupId>commons-beanutils</groupId>
- <artifactId>commons-beanutils</artifactId>
- <version>${commons-beanutils-version}</version>
- </dependency>
- </dependencies>
-
- <build>
- <plugins>
- <plugin>
- <artifactId>maven-surefire-plugin</artifactId>
- <configuration>
- <systemPropertyVariables>
- <org.slf4j.simpleLogger.defaultLogLevel>warn</org.slf4j.simpleLogger.defaultLogLevel>
- </systemPropertyVariables>
- </configuration>
- </plugin>
- </plugins>
- </build>
-
-</project>
diff --git a/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraComponentConfigurer.java b/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraComponentConfigurer.java
deleted file mode 100644
index 90965266674..00000000000
--- a/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraComponentConfigurer.java
+++ /dev/null
@@ -1,61 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.gora;
-
-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 GoraComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- GoraComponent target = (GoraComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": target.setAutowiredEnabled(property(camelContext, boolean.class, value)); return true;
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- default: return false;
- }
- }
-
- @Override
- public Class<?> getOptionType(String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": return boolean.class;
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return boolean.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- GoraComponent target = (GoraComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": return target.isAutowiredEnabled();
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraEndpointConfigurer.java b/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraEndpointConfigurer.java
deleted file mode 100644
index 837404f26dc..00000000000
--- a/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraEndpointConfigurer.java
+++ /dev/null
@@ -1,160 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.gora;
-
-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 GoraEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- GoraEndpoint target = (GoraEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
- case "concurrentconsumers":
- case "concurrentConsumers": target.getConfiguration().setConcurrentConsumers(property(camelContext, int.class, value)); return true;
- case "datastoreclass":
- case "dataStoreClass": target.getConfiguration().setDataStoreClass(property(camelContext, java.lang.String.class, value)); return true;
- case "endkey":
- case "endKey": target.getConfiguration().setEndKey(property(camelContext, java.lang.Object.class, value)); return true;
- case "endtime":
- case "endTime": target.getConfiguration().setEndTime(property(camelContext, long.class, value)); return true;
- case "exceptionhandler":
- case "exceptionHandler": target.setExceptionHandler(property(camelContext, org.apache.camel.spi.ExceptionHandler.class, value)); return true;
- case "exchangepattern":
- case "exchangePattern": target.setExchangePattern(property(camelContext, org.apache.camel.ExchangePattern.class, value)); return true;
- case "fields": target.getConfiguration().setFields(property(camelContext, com.google.common.base.Strings.class, value)); return true;
- case "flushoneveryoperation":
- case "flushOnEveryOperation": target.getConfiguration().setFlushOnEveryOperation(property(camelContext, boolean.class, value)); return true;
- case "hadoopconfiguration":
- case "hadoopConfiguration": target.getConfiguration().setHadoopConfiguration(property(camelContext, org.apache.hadoop.conf.Configuration.class, value)); return true;
- case "keyclass":
- case "keyClass": target.getConfiguration().setKeyClass(property(camelContext, java.lang.String.class, value)); return true;
- case "keyrangefrom":
- case "keyRangeFrom": target.getConfiguration().setKeyRangeFrom(property(camelContext, java.lang.Object.class, value)); return true;
- case "keyrangeto":
- case "keyRangeTo": target.getConfiguration().setKeyRangeTo(property(camelContext, java.lang.Object.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "limit": target.getConfiguration().setLimit(property(camelContext, long.class, value)); return true;
- case "startkey":
- case "startKey": target.getConfiguration().setStartKey(property(camelContext, java.lang.Object.class, value)); return true;
- case "starttime":
- case "startTime": target.getConfiguration().setStartTime(property(camelContext, long.class, value)); return true;
- case "timerangefrom":
- case "timeRangeFrom": target.getConfiguration().setTimeRangeFrom(property(camelContext, long.class, value)); return true;
- case "timerangeto":
- case "timeRangeTo": target.getConfiguration().setTimeRangeTo(property(camelContext, long.class, value)); return true;
- case "timestamp": target.getConfiguration().setTimestamp(property(camelContext, long.class, value)); return true;
- case "valueclass":
- case "valueClass": target.getConfiguration().setValueClass(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 "bridgeerrorhandler":
- case "bridgeErrorHandler": return boolean.class;
- case "concurrentconsumers":
- case "concurrentConsumers": return int.class;
- case "datastoreclass":
- case "dataStoreClass": return java.lang.String.class;
- case "endkey":
- case "endKey": return java.lang.Object.class;
- case "endtime":
- case "endTime": return long.class;
- case "exceptionhandler":
- case "exceptionHandler": return org.apache.camel.spi.ExceptionHandler.class;
- case "exchangepattern":
- case "exchangePattern": return org.apache.camel.ExchangePattern.class;
- case "fields": return com.google.common.base.Strings.class;
- case "flushoneveryoperation":
- case "flushOnEveryOperation": return boolean.class;
- case "hadoopconfiguration":
- case "hadoopConfiguration": return org.apache.hadoop.conf.Configuration.class;
- case "keyclass":
- case "keyClass": return java.lang.String.class;
- case "keyrangefrom":
- case "keyRangeFrom": return java.lang.Object.class;
- case "keyrangeto":
- case "keyRangeTo": return java.lang.Object.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "limit": return long.class;
- case "startkey":
- case "startKey": return java.lang.Object.class;
- case "starttime":
- case "startTime": return long.class;
- case "timerangefrom":
- case "timeRangeFrom": return long.class;
- case "timerangeto":
- case "timeRangeTo": return long.class;
- case "timestamp": return long.class;
- case "valueclass":
- case "valueClass": return java.lang.String.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- GoraEndpoint target = (GoraEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "concurrentconsumers":
- case "concurrentConsumers": return target.getConfiguration().getConcurrentConsumers();
- case "datastoreclass":
- case "dataStoreClass": return target.getConfiguration().getDataStoreClass();
- case "endkey":
- case "endKey": return target.getConfiguration().getEndKey();
- case "endtime":
- case "endTime": return target.getConfiguration().getEndTime();
- case "exceptionhandler":
- case "exceptionHandler": return target.getExceptionHandler();
- case "exchangepattern":
- case "exchangePattern": return target.getExchangePattern();
- case "fields": return target.getConfiguration().getFields();
- case "flushoneveryoperation":
- case "flushOnEveryOperation": return target.getConfiguration().isFlushOnEveryOperation();
- case "hadoopconfiguration":
- case "hadoopConfiguration": return target.getConfiguration().getHadoopConfiguration();
- case "keyclass":
- case "keyClass": return target.getConfiguration().getKeyClass();
- case "keyrangefrom":
- case "keyRangeFrom": return target.getConfiguration().getKeyRangeFrom();
- case "keyrangeto":
- case "keyRangeTo": return target.getConfiguration().getKeyRangeTo();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "limit": return target.getConfiguration().getLimit();
- case "startkey":
- case "startKey": return target.getConfiguration().getStartKey();
- case "starttime":
- case "startTime": return target.getConfiguration().getStartTime();
- case "timerangefrom":
- case "timeRangeFrom": return target.getConfiguration().getTimeRangeFrom();
- case "timerangeto":
- case "timeRangeTo": return target.getConfiguration().getTimeRangeTo();
- case "timestamp": return target.getConfiguration().getTimestamp();
- case "valueclass":
- case "valueClass": return target.getConfiguration().getValueClass();
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraEndpointUriFactory.java b/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraEndpointUriFactory.java
deleted file mode 100644
index 03e149b5ba2..00000000000
--- a/components/camel-gora/src/generated/java/org/apache/camel/component/gora/GoraEndpointUriFactory.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.gora;
-
-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 GoraEndpointUriFactory extends org.apache.camel.support.component.EndpointUriFactorySupport implements EndpointUriFactory {
-
- private static final String BASE = ":name";
-
- 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<>(22);
- props.add("bridgeErrorHandler");
- props.add("concurrentConsumers");
- props.add("dataStoreClass");
- props.add("endKey");
- props.add("endTime");
- props.add("exceptionHandler");
- props.add("exchangePattern");
- props.add("fields");
- props.add("flushOnEveryOperation");
- props.add("hadoopConfiguration");
- props.add("keyClass");
- props.add("keyRangeFrom");
- props.add("keyRangeTo");
- props.add("lazyStartProducer");
- props.add("limit");
- props.add("name");
- props.add("startKey");
- props.add("startTime");
- props.add("timeRangeFrom");
- props.add("timeRangeTo");
- props.add("timestamp");
- props.add("valueClass");
- PROPERTY_NAMES = Collections.unmodifiableSet(props);
- SECRET_PROPERTY_NAMES = Collections.emptySet();
- MULTI_VALUE_PREFIXES = Collections.emptySet();
- }
-
- @Override
- public boolean isEnabled(String scheme) {
- return "gora".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, "name", 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-gora/src/generated/resources/META-INF/services/org/apache/camel/component.properties b/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/component.properties
deleted file mode 100644
index 09b4d879b07..00000000000
--- a/components/camel-gora/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=gora
-groupId=org.apache.camel
-artifactId=camel-gora
-version=4.0.0-SNAPSHOT
-projectName=Camel :: Gora
-projectDescription=Gora Component for Apache Camel
diff --git a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/component/gora b/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/component/gora
deleted file mode 100644
index 9a583c63bf8..00000000000
--- a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/component/gora
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.gora.GoraComponent
diff --git a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/configurer/gora-component b/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/configurer/gora-component
deleted file mode 100644
index 60483d6249b..00000000000
--- a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/configurer/gora-component
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.gora.GoraComponentConfigurer
diff --git a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/configurer/gora-endpoint b/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/configurer/gora-endpoint
deleted file mode 100644
index a05c4972c02..00000000000
--- a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/configurer/gora-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.gora.GoraEndpointConfigurer
diff --git a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/urifactory/gora-endpoint b/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/urifactory/gora-endpoint
deleted file mode 100644
index 6d7cbf2e29c..00000000000
--- a/components/camel-gora/src/generated/resources/META-INF/services/org/apache/camel/urifactory/gora-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.gora.GoraEndpointUriFactory
diff --git a/components/camel-gora/src/generated/resources/org/apache/camel/component/gora/gora.json b/components/camel-gora/src/generated/resources/org/apache/camel/component/gora/gora.json
deleted file mode 100644
index c7ffda5919a..00000000000
--- a/components/camel-gora/src/generated/resources/org/apache/camel/component/gora/gora.json
+++ /dev/null
@@ -1,57 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "gora",
- "title": "Gora",
- "description": "Access NoSQL databases using the Apache Gora framework.",
- "deprecated": false,
- "firstVersion": "2.14.0",
- "label": "database,nosql,bigdata",
- "javaType": "org.apache.camel.component.gora.GoraComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-gora",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "gora",
- "extendsScheme": "",
- "syntax": "gora:name",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
- "componentProperties": {
- "bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a me [...]
- "lazyStartProducer": { "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 during star [...]
- "autowiredEnabled": { "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 type, which t [...]
- },
- "headers": {
- "goraKey": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Object", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Used in order to define the datum key for the operations need it.", "constantName": "org.apache.camel.component.gora.GoraAttribute#GORA_KEY@value" },
- "goraOperation": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Used in order to define the operation to execute.", "constantName": "org.apache.camel.component.gora.GoraAttribute#GORA_OPERATION@value" }
- },
- "properties": {
- "name": { "kind": "path", "displayName": "Name", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Instance name" },
- "dataStoreClass": { "kind": "parameter", "displayName": "Data Store Class", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The type of the dataStore" },
- "keyClass": { "kind": "parameter", "displayName": "Key Class", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The type class of the key" },
- "valueClass": { "kind": "parameter", "displayName": "Value Class", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The type of the value" },
- "concurrentConsumers": { "kind": "parameter", "displayName": "Concurrent Consumers", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Number of concurrent consumers" },
- "endKey": { "kind": "parameter", "displayName": "End Key", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The End Key" },
- "endTime": { "kind": "parameter", "displayName": "End Time", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The End Time" },
- "fields": { "kind": "parameter", "displayName": "Fields", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "com.google.common.base.Strings", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Fields" },
- "keyRangeFrom": { "kind": "parameter", "displayName": "Key Range From", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Key Range From" },
- "keyRangeTo": { "kind": "parameter", "displayName": "Key Range To", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Key Range To" },
- "limit": { "kind": "parameter", "displayName": "Limit", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Limit" },
- "startKey": { "kind": "parameter", "displayName": "Start Key", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "java.lang.Object", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Start Key" },
- "startTime": { "kind": "parameter", "displayName": "Start Time", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Start Time" },
- "timeRangeFrom": { "kind": "parameter", "displayName": "Time Range From", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Time Range From" },
- "timeRangeTo": { "kind": "parameter", "displayName": "Time Range To", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Time Range To" },
- "timestamp": { "kind": "parameter", "displayName": "Timestamp", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "The Timestamp" },
- "bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now [...]
- "exceptionHandler": { "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the con [...]
- "exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "flushOnEveryOperation": { "kind": "parameter", "displayName": "Flush On Every Operation", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Flush on every operation" },
- "lazyStartProducer": { "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 producer may other [...]
- "hadoopConfiguration": { "kind": "parameter", "displayName": "Hadoop Configuration", "group": "advanced", "label": "advanced", "required": false, "type": "object", "javaType": "org.apache.hadoop.conf.Configuration", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.gora.GoraConfiguration", "configurationField": "configuration", "description": "Hadoop Configuration" }
- }
-}
diff --git a/components/camel-gora/src/main/docs/gora-component.adoc b/components/camel-gora/src/main/docs/gora-component.adoc
deleted file mode 100644
index 6a775bb2488..00000000000
--- a/components/camel-gora/src/main/docs/gora-component.adoc
+++ /dev/null
@@ -1,222 +0,0 @@
-= Gora Component
-:doctitle: Gora
-:shortname: gora
-:artifactid: camel-gora
-:description: Access NoSQL databases using the Apache Gora framework.
-:since: 2.14
-:supportlevel: Stable
-:component-header: Both producer and consumer are supported
-//Manually maintained attributes
-:camel-spring-boot-name: gora
-
-*Since Camel {since}*
-
-*{component-header}*
-
-*Camel-Gora* is an http://camel.apache.org/[Apache Camel] component that
-allows you to work with NoSQL databases using the
-http://gora.apache.org/[Apache Gora] framework.
-
-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-gora</artifactId>
- <!-- use the same version as your Camel core version -->
- <version>x.x.x</version>
-</dependency>
----------------------------------------------------------
-
-== Apache Gora Overview
-
-The http://gora.apache.org/[Apache Gora] open source framework provides
-an in-memory data model and persistence for big data. Gora supports
-persisting to column stores, key value stores, document stores and
-RDBMSs, and analyzing the data with extensive
-http://hadoop.apache.org/[Apache Hadoop™ MapReduce] support. Gora uses
-the http://www.apache.org/licenses/LICENSE-2.0.html[Apache Software
-License v2.0] and graduated from the Apache Incubator in Janauary 2012
-to become a top-level Apache project.
-
-Apache Gora currently supports the following datastores:
-http://hbase.apache.org/[Apache HBase],
-http://cassandra.apache.org/[Apache Cassandra],
-http://accumulo.apache.org/[Apache Accumulo],
-https://aws.amazon.com/dynamodb/[Amazon DynamoDB] and SQL databases such
-as http://hsqldb.org/[hsqldb], http://www.mysql.com/[MySQL] and more.
-
-== URI format
-
----------------------------
-gora:instanceName[?options]
----------------------------
-
-Hbase examples with mandatory options :
-
-_XML_
-
-[source,xml]
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-<to uri="gora:foobar?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore"/>
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-_Java DSL_
-
-[source,java]
--------------------------------------------------------------------------------------------------------------------------------------------------------------
-to("gora:foobar?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore")
--------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-== Configuration
-
-Using camel-gora needs some configuration. This mainly involve to
-configure the _AvroStore_ through the _gora.properties_ file and to
-define the relevant mappings as part of the
-_http://gora.apache.org/current/gora-core.html[gora-core]_ module.
-
-Extensive information for this configuration can be found in the apache
-http://gora.apache.org/current/index.html[gora documentation] and the
-http://gora.apache.org/current/gora-conf.html[gora-conf] page.
-
-
-
-// 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
-
-
-== Supported Gora Operations
-
-Supported operations include : *put*, *get*, *delete*, *getSchemaName*,
-*deleteSchema*, *createSchema*, *query*, *deleteByQuery*,
-*schemaExists*.
-
-Some operations require arguments while some others no. The
-arguments to operations could be either the _body_ of the _in_ message
-or defined in a header property. Below there is a list with some
-additional info for each operation.
-
-[width="100%",cols="10%,90%",options="header",]
-|=======================================================================
-|Property |Description
-
-|put |_Inserts the persistent object with the given key._
-
-|get |_Returns the object corresponding to the given key fetching all the
-fields._
-
-|delete |_Deletes the object with the given key._
-
-|getSchemaName |_Returns the schema name given to this DataStore._
-
-|deleteSchema |_Deletes the underlying schema or table (or similar) in the datastore
-that holds the objects._
-
-|createSchema |_Creates the optional schema or table (or similar) in the datastore to
-hold the objects._
-
-|query |_Executes the given query and returns the results._
-
-|deleteByQuery |_Deletes all the objects matching the query._
-
-|schemaExists |_Returns whether the schema that holds the data exists in the
-datastore._
-|=======================================================================
-
-== Usage examples
-
-*Create Schema* _(XML DSL)_:
-
-[source,xml]
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-<setHeader name="GoraOperation">
- <constant>CreateSchema</constant>
-</setHeader>
-<to uri="gora:foobar?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore"/>
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-*SchemaExists* _(XML DSL)_:
-
-[source,xml]
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-<setHeader name="GoraOperation">
- <constant>SchemaExists</constant>
-</setHeader>
- <to uri="gora:foobar?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore"/>
-----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-*Put* _(XML DSL)_:
-
-[source,xml]
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-<setHeader name="GoraOperation">
- <constant>put</constant>
-</setHeader>
-<setHeader name="GoraKey">
- <constant>22222</constant>
-</setHeader>
-<to uri="gora:foo?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore"/>
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-*Get* _(XML DSL)_:
-
-[source,xml]
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-<setHeader name="GoraOperation">
- <constant>GET</constant>
-</setHeader>
-<setHeader name="GoraKey">
- <constant>10101</constant>
-</setHeader>
-<to uri="gora:bar?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore"/>
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-*Delete* _(XML DSL)_:
-
-[source,xml]
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-<setHeader name="GoraOperation">
- <constant>DELETE</constant>
-</setHeader>
-<setHeader name="GoraKey">
- <constant>22222</constant>
-</setHeader>
-<to uri="gora:bar?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore"/>
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-*Query* _(XML DSL)_:
-
-[source,xml]
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-<to uri="gora:foobar?keyClass=java.lang.Long&valueClass=org.apache.camel.component.gora.generated.Pageview&dataStoreClass=org.apache.gora.hbase.store.HBaseStore"/>
----------------------------------------------------------------------------------------------------------------------------------------------------------------------------
-
-The full usage examples in the form of integration tests can be found at
-https://github.com/ipolyzos/camel-gora-examples/[camel-gora-examples]
-repository.
-
-== More resources
-
-For more please information and in depth configuration refer to the
-http://gora.apache.org/current/overview.html[Apache Gora Documentation]
-and the http://gora.apache.org/current/tutorial.html[Apache Gora
-Tutorial].
-
-
-include::spring-boot:partial$starter.adoc[]
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraAttribute.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraAttribute.java
deleted file mode 100644
index ca47d563ee9..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraAttribute.java
+++ /dev/null
@@ -1,108 +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.gora;
-
-import org.apache.camel.spi.Metadata;
-
-/**
- * Camel-Gora attributes
- */
-public enum GoraAttribute {
-
- /**
- * Gora KEY attribute
- */
- @Metadata(label = "producer", description = "Used in order to define the datum key for the operations need it.",
- javaType = "Object")
- GORA_KEY("goraKey"),
-
- /**
- * Gora operation header name
- */
- @Metadata(label = "producer", description = "Used in order to define the operation to execute.", javaType = "String")
- GORA_OPERATION("goraOperation"),
-
- /**
- * Gora Query Start Time attribute
- */
- GORA_QUERY_START_TIME("startTime"),
-
- /**
- * Gora Query End Time attribute
- */
- GORA_QUERY_END_TIME("endTime"),
-
- /**
- * Gora Query Start Key attribute
- */
- GORA_QUERY_START_KEY("startKey"),
-
- /**
- * Gora Query End Key attribute
- */
- GORA_QUERY_END_KEY("endKey"),
-
- /**
- * Gora Query Key Range From attribute
- */
- GORA_QUERY_KEY_RANGE_FROM("keyRangeFrom"),
-
- /**
- * Gora Query Key Range To attribute
- */
- GORA_QUERY_KEY_RANGE_TO("keyRangeTo"),
-
- /**
- * Gora Query Time Range From attribute
- */
- GORA_QUERY_TIME_RANGE_FROM("timeRangeFrom"),
-
- /**
- * Gora Query Key Range To attribute
- */
- GORA_QUERY_TIME_RANGE_TO("timeRangeTo"),
-
- /**
- * Gora Query Limit attribute
- */
- GORA_QUERY_LIMIT("limit"),
-
- /**
- * Gora Query Timestamp attribute
- */
- GORA_QUERY_TIMESTAMP("timestamp"),
-
- /**
- * Gora Query Fields attribute
- */
- GORA_QUERY_FIELDS("fields");
-
- /**
- * Enum value
- */
- public final String value;
-
- /**
- * Enum constructor
- *
- * @param str Operation Value
- */
- GoraAttribute(final String str) {
- value = str;
- }
-
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraComponent.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraComponent.java
deleted file mode 100644
index 6cf29596ffb..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraComponent.java
+++ /dev/null
@@ -1,106 +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.gora;
-
-import java.io.IOException;
-import java.util.Map;
-import java.util.Properties;
-
-import org.apache.camel.Endpoint;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.camel.support.DefaultComponent;
-import org.apache.gora.persistency.Persistent;
-import org.apache.gora.store.DataStore;
-import org.apache.gora.store.DataStoreFactory;
-import org.apache.hadoop.conf.Configuration;
-
-import static org.apache.camel.component.gora.GoraConstants.GORA_DEFAULT_DATASTORE_KEY;
-
-@Component("gora")
-public class GoraComponent extends DefaultComponent {
-
- /**
- * GORA datastore
- */
- private DataStore<Object, Persistent> dataStore;
-
- /**
- * GORA properties
- */
- private Properties goraProperties;
-
- /**
- * Hadoop configuration
- */
- private Configuration configuration;
-
- public GoraComponent() {
- }
-
- /**
- * Initialize class and create DataStore instance
- *
- * @param config component configuration
- * @throws IOException
- */
- private void init(final GoraConfiguration config) throws IOException {
- this.goraProperties = DataStoreFactory.createProps();
- this.dataStore = DataStoreFactory.getDataStore(goraProperties.getProperty(GORA_DEFAULT_DATASTORE_KEY,
- config.getDataStoreClass()),
- config.getKeyClass(),
- config.getValueClass(),
- this.configuration);
- }
-
- @Override
- protected Endpoint createEndpoint(
- final String uri,
- final String remaining,
- final Map<String, Object> parameters)
- throws Exception {
-
- GoraConfiguration config = new GoraConfiguration();
- config.setName(remaining);
-
- GoraEndpoint endpoint = new GoraEndpoint(uri, this, config, dataStore);
- setProperties(endpoint, parameters);
- init(config);
- return endpoint;
- }
-
- /**
- * Get DataStore
- */
- public DataStore<Object, Persistent> getDataStore() {
- return dataStore;
- }
-
- @Override
- protected void doStart() throws Exception {
- if (configuration == null) {
- configuration = new Configuration();
- }
- }
-
- @Override
- protected void doStop() throws Exception {
- if (dataStore != null) {
- dataStore.close();
- }
- }
-
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConfiguration.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConfiguration.java
deleted file mode 100644
index 496b1c2d6f1..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConfiguration.java
+++ /dev/null
@@ -1,286 +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.gora;
-
-import com.google.common.base.Strings;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriParams;
-import org.apache.camel.spi.UriPath;
-import org.apache.hadoop.conf.Configuration;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-import static com.google.common.base.Strings.isNullOrEmpty;
-
-/**
- * Gora Configuration.
- */
-@UriParams
-public class GoraConfiguration {
-
- @UriPath
- @Metadata(required = true)
- private String name;
- @UriParam
- private String keyClass;
- @UriParam
- private String valueClass;
- @UriParam
- private String dataStoreClass;
- @UriParam(label = "advanced")
- private Configuration hadoopConfiguration;
-
- @UriParam(label = "consumer")
- private long startTime;
- @UriParam(label = "consumer")
- private long endTime;
- @UriParam(label = "consumer")
- private long timeRangeFrom;
- @UriParam(label = "consumer")
- private long timeRangeTo;
- @UriParam(label = "consumer")
- private long limit;
- @UriParam(label = "consumer")
- private long timestamp;
- @UriParam(label = "consumer")
- private Object startKey;
- @UriParam(label = "consumer")
- private Object endKey;
- @UriParam(label = "consumer")
- private Object keyRangeFrom;
- @UriParam(label = "consumer")
- private Object keyRangeTo;
- @UriParam(label = "consumer")
- private Strings fields;
- @UriParam(label = "consumer", defaultValue = "1")
- private int concurrentConsumers = 1;
- @UriParam(label = "producer", defaultValue = "true")
- private boolean flushOnEveryOperation = true;
-
- public GoraConfiguration() {
- this.hadoopConfiguration = new Configuration();
- }
-
- public String getKeyClass() {
- return keyClass;
- }
-
- /**
- * The type class of the key
- */
- public void setKeyClass(final String keyClass) {
- if (isNullOrEmpty(keyClass)) {
- throw new IllegalArgumentException("Key class could not be null or empty!");
- }
-
- this.keyClass = keyClass;
- }
-
- public String getValueClass() {
- return valueClass;
- }
-
- /**
- * The type of the value
- */
- public void setValueClass(final String valueClass) {
- if (isNullOrEmpty(valueClass)) {
- throw new IllegalArgumentException("Value class could not be null or empty!");
- }
- this.valueClass = valueClass;
- }
-
- public String getDataStoreClass() {
- return dataStoreClass;
- }
-
- /**
- * The type of the dataStore
- */
- public void setDataStoreClass(String dataStoreClass) {
- if (isNullOrEmpty(dataStoreClass)) {
- throw new IllegalArgumentException("DataStore class could not be null or empty!");
- }
- this.dataStoreClass = dataStoreClass;
- }
-
- public Configuration getHadoopConfiguration() {
- return hadoopConfiguration;
- }
-
- public long getStartTime() {
- return startTime;
- }
-
- /**
- * The Start Time
- */
- public void setStartTime(long startTime) {
- this.startTime = startTime;
- }
-
- public long getEndTime() {
- return endTime;
- }
-
- /**
- * The End Time
- */
- public void setEndTime(long endTime) {
- this.endTime = endTime;
- }
-
- public long getTimeRangeFrom() {
- return timeRangeFrom;
- }
-
- /**
- * The Time Range From
- */
- public void setTimeRangeFrom(long timeRangeFrom) {
- this.timeRangeFrom = timeRangeFrom;
- }
-
- public long getTimeRangeTo() {
- return timeRangeTo;
- }
-
- /**
- * The Time Range To
- */
- public void setTimeRangeTo(long timeRangeTo) {
- this.timeRangeTo = timeRangeTo;
- }
-
- public long getLimit() {
- return limit;
- }
-
- /**
- * The Limit
- */
- public void setLimit(long limit) {
- this.limit = limit;
- }
-
- public long getTimestamp() {
- return timestamp;
- }
-
- /**
- * The Timestamp
- */
- public void setTimestamp(long timestamp) {
- this.timestamp = timestamp;
- }
-
- public Object getStartKey() {
- return startKey;
- }
-
- /**
- * The Start Key
- */
- public void setStartKey(Object startKey) {
- this.startKey = startKey;
- }
-
- public Object getEndKey() {
- return endKey;
- }
-
- /**
- * The End Key
- */
- public void setEndKey(Object endKey) {
- this.endKey = endKey;
- }
-
- public Object getKeyRangeFrom() {
- return keyRangeFrom;
- }
-
- /**
- * The Key Range From
- */
- public void setKeyRangeFrom(Object keyRangeFrom) {
- this.keyRangeFrom = keyRangeFrom;
- }
-
- public Object getKeyRangeTo() {
- return keyRangeTo;
- }
-
- /**
- * The Key Range To
- */
- public void setKeyRangeTo(Object keyRangeTo) {
- this.keyRangeTo = keyRangeTo;
- }
-
- public Strings getFields() {
- return fields;
- }
-
- /**
- * The Fields
- */
- public void setFields(Strings fields) {
- this.fields = fields;
- }
-
- public int getConcurrentConsumers() {
- return concurrentConsumers;
- }
-
- /**
- * Number of concurrent consumers
- */
- public void setConcurrentConsumers(int concurrentConsumers) {
- this.concurrentConsumers = concurrentConsumers;
- }
-
- public boolean isFlushOnEveryOperation() {
- return flushOnEveryOperation;
- }
-
- /**
- * Flush on every operation
- */
- public void setFlushOnEveryOperation(boolean flushOnEveryOperation) {
- this.flushOnEveryOperation = flushOnEveryOperation;
- }
-
- /**
- * Hadoop Configuration
- */
- public void setHadoopConfiguration(Configuration hadoopConfiguration) {
- checkNotNull(hadoopConfiguration, "Hadoop Configuration could not be null!");
- this.hadoopConfiguration = hadoopConfiguration;
- }
-
- public String getName() {
- return name;
- }
-
- /**
- * Instance name
- */
- public void setName(String name) {
- this.name = name;
- }
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConstants.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConstants.java
deleted file mode 100644
index 31507e3f185..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConstants.java
+++ /dev/null
@@ -1,36 +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.gora;
-
-/**
- * Camel Gora component constants
- */
-public final class GoraConstants {
-
- /**
- * default DataStore key
- */
- public static final String GORA_DEFAULT_DATASTORE_KEY = "gora.datastore.default";
-
- /**
- * Private constructor
- */
- private GoraConstants() {
- // prevent instantiation
- }
-
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConsumer.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConsumer.java
deleted file mode 100644
index f9b226b3988..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraConsumer.java
+++ /dev/null
@@ -1,95 +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.gora;
-
-import java.lang.reflect.InvocationTargetException;
-
-import org.apache.camel.Consumer;
-import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.component.gora.utils.GoraUtils;
-import org.apache.camel.support.ScheduledPollConsumer;
-import org.apache.gora.persistency.Persistent;
-import org.apache.gora.query.Query;
-import org.apache.gora.query.Result;
-import org.apache.gora.store.DataStore;
-
-/**
- * Implementation of Camel-Gora {@link Consumer}.
- */
-public class GoraConsumer extends ScheduledPollConsumer {
-
- /**
- * GORA datastore
- */
- private final DataStore<Object, Persistent> dataStore;
-
- /**
- * Camel-Gora endpoint configuration
- */
- private final GoraConfiguration configuration;
-
- /**
- * Camel Gora Query
- */
- private Query query;
-
- /**
- * Poll run
- */
- private boolean firstRun;
-
- /**
- * Consumer Constructor
- *
- * @param endpoint Reference to the Camel-Gora endpoint
- * @param processor Reference to Consumer Processor
- * @param configuration Reference to Camel-Gora endpoint configuration
- * @param dataStore Reference to the datastore
- */
- public GoraConsumer(final Endpoint endpoint,
- final Processor processor,
- final GoraConfiguration configuration,
- final DataStore<Object, Persistent> dataStore) throws NoSuchMethodException,
- InvocationTargetException, IllegalAccessException {
-
- super(endpoint, processor);
- this.configuration = configuration;
- this.dataStore = dataStore;
- this.query = GoraUtils.constractQueryFromConfiguration(this.dataStore, this.configuration);
- }
-
- @Override
- protected int poll() throws Exception {
- final Exchange exchange = createExchange(true);
-
- // compute time (approx) since last update
- if (firstRun) {
- this.query.setStartTime(System.currentTimeMillis());
- } else {
- this.query.setStartTime(System.currentTimeMillis() - getDelay());
- }
-
- //proceed with query
- final Result result = query.execute();
-
- getProcessor().process(exchange);
-
- return (int) result.getOffset();
- }
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraEndpoint.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraEndpoint.java
deleted file mode 100644
index df078ab0db6..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraEndpoint.java
+++ /dev/null
@@ -1,80 +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.gora;
-
-import org.apache.camel.Category;
-import org.apache.camel.Consumer;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.spi.UriEndpoint;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.support.DefaultEndpoint;
-import org.apache.gora.persistency.Persistent;
-import org.apache.gora.store.DataStore;
-
-/**
- * Access NoSQL databases using the Apache Gora framework.
- */
-@UriEndpoint(firstVersion = "2.14.0", scheme = "gora", title = "Gora", syntax = "gora:name",
- category = { Category.DATABASE, Category.NOSQL, Category.BIGDATA }, headersClass = GoraAttribute.class,
- headersNameProvider = "value")
-public class GoraEndpoint extends DefaultEndpoint {
-
- /**
- * Gora DataStore
- */
- private final DataStore<Object, Persistent> dataStore;
-
- /**
- * Camel-Gora Endpoint Configuration
- */
- @UriParam
- private GoraConfiguration configuration;
-
- /**
- * GORA endpoint default constructor
- *
- * @param uri Endpoint URI
- * @param goraComponent Reference to the Camel-Gora component
- * @param config Reference to Camel-Gora endpoint configuration
- * @param dataStore Reference to Gora DataStore
- */
- public GoraEndpoint(final String uri,
- final GoraComponent goraComponent,
- final GoraConfiguration config,
- final DataStore<Object, Persistent> dataStore) {
-
- super(uri, goraComponent);
- this.configuration = config;
- this.dataStore = dataStore;
- }
-
- @Override
- public Producer createProducer() throws Exception {
- return new GoraProducer(this, this.configuration, this.dataStore);
- }
-
- @Override
- public Consumer createConsumer(final Processor processor) throws Exception {
- return new GoraConsumer(this, processor, this.configuration, this.dataStore);
- }
-
- public GoraConfiguration getConfiguration() {
- return configuration;
- }
-
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraOperation.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraOperation.java
deleted file mode 100644
index c90275dda49..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraOperation.java
+++ /dev/null
@@ -1,80 +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.gora;
-
-/**
- * Camel-Gora Operations.
- */
-public enum GoraOperation {
-
- /**
- * Gora "put" operation
- */
- PUT("put"),
-
- /**
- * Gora fetch/"get" operation
- */
- GET("get"),
-
- /**
- * Gora "delete" operation
- */
- DELETE("delete"),
-
- /**
- * Gora "get schema name" operation
- */
- GET_SCHEMA_NAME("getSchemaName"),
-
- /**
- * Gora "delete schema" operation
- */
- DELETE_SCHEMA("deleteSchema"),
-
- /**
- * Gora "create schema" operation
- */
- CREATE_SCHEMA("createSchema"),
-
- /**
- * Gora "query" operation
- */
- QUERY("query"),
-
- /**
- * Gora "deleteByQuery" operation
- */
- DELETE_BY_QUERY("deleteByQuery"),
-
- /**
- * Gora "schemaExists" operation
- */
- SCHEMA_EXIST("schemaExists");
-
- /**
- * Enum value
- */
- public final String value;
-
- /**
- * Enum constructor
- */
- GoraOperation(final String str) {
- value = str;
- }
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraProducer.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraProducer.java
deleted file mode 100644
index f3579d40ac3..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/GoraProducer.java
+++ /dev/null
@@ -1,110 +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.gora;
-
-import java.util.Map;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.support.DefaultProducer;
-import org.apache.gora.persistency.Persistent;
-import org.apache.gora.store.DataStore;
-
-import static org.apache.camel.component.gora.utils.GoraUtils.constructQueryFromPropertiesMap;
-import static org.apache.camel.component.gora.utils.GoraUtils.getKeyFromExchange;
-import static org.apache.camel.component.gora.utils.GoraUtils.getValueFromExchange;
-
-/**
- * Camel-Gora {@link DefaultProducer}.
- */
-public class GoraProducer extends DefaultProducer {
-
- /**
- * Camel-Gora endpoint configuration
- */
- private final GoraConfiguration configuration;
-
- /**
- * GORA datastore
- */
- private final DataStore<Object, Persistent> dataStore;
-
- /**
- * Constructor
- *
- * @param endpoint Reference to the Camel-Gora endpoint
- * @param configuration Reference to Camel-Gora endpoint configuration
- * @param dataStore Reference to the datastore
- */
- public GoraProducer(final GoraEndpoint endpoint,
- final GoraConfiguration configuration,
- final DataStore<Object, Persistent> dataStore) {
-
- super(endpoint);
- this.dataStore = dataStore;
- this.configuration = configuration;
- }
-
- @Override
- public void process(final Exchange exchange) throws Exception {
- final String operation = (String) exchange.getIn().getHeader(GoraAttribute.GORA_OPERATION.value);
-
- if (operation == null || operation.isEmpty()) {
- throw new RuntimeCamelException("Gora operation is null or empty!");
- }
-
- Object result = 0; // 0 used as default response in order to avoid null body exception
-
- if (GoraOperation.PUT.value.equalsIgnoreCase(operation)) {
- dataStore.put(getKeyFromExchange(exchange), getValueFromExchange(exchange));
- } else if (GoraOperation.GET.value.equalsIgnoreCase(operation)) {
- result = dataStore.get(getKeyFromExchange(exchange));
- } else if (GoraOperation.DELETE.value.equalsIgnoreCase(operation)) {
- result = dataStore.delete(getKeyFromExchange(exchange));
- } else if (GoraOperation.QUERY.value.equalsIgnoreCase(operation)) {
- final Map<String, Object> props = exchange.getIn().getHeaders();
- result = constructQueryFromPropertiesMap(props, dataStore).execute();
- } else if (GoraOperation.DELETE_BY_QUERY.value.equalsIgnoreCase(operation)) {
- final Map<String, Object> props = exchange.getIn().getHeaders();
- result = dataStore.deleteByQuery(constructQueryFromPropertiesMap(props, dataStore));
- } else if (GoraOperation.GET_SCHEMA_NAME.value.equalsIgnoreCase(operation)) {
- result = dataStore.getSchemaName();
- } else if (GoraOperation.DELETE_SCHEMA.value.equalsIgnoreCase(operation)) {
- dataStore.deleteSchema();
- } else if (GoraOperation.CREATE_SCHEMA.value.equalsIgnoreCase(operation)) {
- dataStore.createSchema();
- } else if (GoraOperation.SCHEMA_EXIST.value.equalsIgnoreCase(operation)) {
- result = dataStore.schemaExists();
- } else {
- throw new RuntimeCamelException("Unknown operation: " + operation);
- }
-
- /*
- from the tests auto-flush seems not to work always
- therefore a temporary solution is calling flush
- on every action
- */
- if (configuration.isFlushOnEveryOperation()) {
- dataStore.flush();
- }
-
- exchange.getMessage().setBody(result);
- // preserve headers
- exchange.getMessage().setHeaders(exchange.getIn().getHeaders());
- }
-
-}
diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java
deleted file mode 100644
index 0b11d4437c8..00000000000
--- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java
+++ /dev/null
@@ -1,248 +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.gora.utils;
-
-import java.lang.reflect.InvocationTargetException;
-import java.util.Map;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.component.gora.GoraAttribute;
-import org.apache.camel.component.gora.GoraConfiguration;
-import org.apache.commons.beanutils.PropertyUtils;
-import org.apache.gora.persistency.Persistent;
-import org.apache.gora.query.Query;
-import org.apache.gora.store.DataStore;
-
-import static com.google.common.base.Preconditions.checkNotNull;
-
-/**
- * GoraUtil class contain utility methods for the camel component.
- */
-public final class GoraUtils {
-
- /**
- * Private Constructor to prevent instantiation of the class.
- */
- private GoraUtils() {
- // utility Class
- }
-
- /**
- * Utility method to construct a new query from the exchange
- *
- * <b>NOTE:</b> values used in order construct the query should be stored in the "in" message headers.
- */
- public static Query<Object, Persistent> constractQueryFromConfiguration(
- final DataStore<Object, Persistent> dataStore, final GoraConfiguration conf)
- throws IllegalAccessException, NoSuchMethodException, InvocationTargetException {
-
- final Query<Object, Persistent> query = dataStore.newQuery();
-
- if (configurationExist(GoraAttribute.GORA_QUERY_START_TIME, conf)) {
- query.setStartTime(getAttributeAsLong(GoraAttribute.GORA_QUERY_START_TIME, conf));
- }
-
- if (configurationExist(GoraAttribute.GORA_QUERY_END_TIME, conf)) {
- query.setEndTime(getAttributeAsLong(GoraAttribute.GORA_QUERY_END_TIME, conf));
- }
-
- if (configurationExist(GoraAttribute.GORA_QUERY_LIMIT, conf)) {
- query.setLimit(getAttributeAsLong(GoraAttribute.GORA_QUERY_LIMIT, conf));
- }
-
- if (configurationExist(GoraAttribute.GORA_QUERY_TIME_RANGE_FROM, conf)
- && configurationExist(GoraAttribute.GORA_QUERY_TIME_RANGE_TO, conf)) {
- query.setTimeRange(getAttributeAsLong(GoraAttribute.GORA_QUERY_TIME_RANGE_FROM, conf),
- getAttributeAsLong(GoraAttribute.GORA_QUERY_TIME_RANGE_TO, conf));
- }
-
- if (configurationExist(GoraAttribute.GORA_QUERY_TIMESTAMP, conf)) {
- query.setTimestamp(getAttributeAsLong(GoraAttribute.GORA_QUERY_TIMESTAMP, conf));
- }
-
- if (configurationExist(GoraAttribute.GORA_QUERY_START_KEY, conf)) {
- query.setStartKey(getAttribute(GoraAttribute.GORA_QUERY_START_KEY, conf));
- }
-
- if (configurationExist(GoraAttribute.GORA_QUERY_END_KEY, conf)) {
- query.setEndKey(getAttribute(GoraAttribute.GORA_QUERY_END_KEY, conf));
- }
-
- if (configurationExist(GoraAttribute.GORA_QUERY_KEY_RANGE_FROM, conf)
- && configurationExist(GoraAttribute.GORA_QUERY_KEY_RANGE_TO, conf)) {
- query.setKeyRange(getAttribute(GoraAttribute.GORA_QUERY_KEY_RANGE_FROM, conf),
- getAttribute(GoraAttribute.GORA_QUERY_KEY_RANGE_TO, conf));
- }
-
- return query;
- }
-
- /**
- * Utility method to construct a new query from the exchange
- *
- * <b>NOTE:</b> values used in order construct the query should be stored in the "in" message headers.
- */
- public static Query<Object, Persistent> constructQueryFromPropertiesMap(
- final Map<String, ?> propertiesMap,
- final DataStore<Object, Persistent> dataStore) {
-
- final Query<Object, Persistent> query = dataStore.newQuery();
-
- if (propertyExist(GoraAttribute.GORA_QUERY_START_TIME, propertiesMap)) {
- query.setStartTime(getPropertyAsLong(GoraAttribute.GORA_QUERY_START_TIME, propertiesMap));
- }
-
- if (propertyExist(GoraAttribute.GORA_QUERY_END_TIME, propertiesMap)) {
- query.setEndTime(getPropertyAsLong(GoraAttribute.GORA_QUERY_END_TIME, propertiesMap));
- }
-
- if (propertyExist(GoraAttribute.GORA_QUERY_LIMIT, propertiesMap)) {
- query.setLimit(getPropertyAsLong(GoraAttribute.GORA_QUERY_LIMIT, propertiesMap));
- }
-
- if (propertyExist(GoraAttribute.GORA_QUERY_TIME_RANGE_FROM, propertiesMap)
- && propertyExist(GoraAttribute.GORA_QUERY_TIME_RANGE_TO, propertiesMap)) {
- query.setTimeRange(getPropertyAsLong(GoraAttribute.GORA_QUERY_TIME_RANGE_FROM, propertiesMap),
- getPropertyAsLong(GoraAttribute.GORA_QUERY_TIME_RANGE_TO, propertiesMap));
- }
-
- if (propertyExist(GoraAttribute.GORA_QUERY_TIMESTAMP, propertiesMap)) {
- query.setTimestamp(getPropertyAsLong(GoraAttribute.GORA_QUERY_TIMESTAMP, propertiesMap));
- }
-
- if (propertyExist(GoraAttribute.GORA_QUERY_START_KEY, propertiesMap)) {
- query.setStartKey(getProperty(GoraAttribute.GORA_QUERY_START_KEY, propertiesMap));
- }
-
- if (propertyExist(GoraAttribute.GORA_QUERY_END_KEY, propertiesMap)) {
- query.setStartKey(getProperty(GoraAttribute.GORA_QUERY_END_KEY, propertiesMap));
- }
-
- if (propertyExist(GoraAttribute.GORA_QUERY_KEY_RANGE_FROM, propertiesMap)
- && propertyExist(GoraAttribute.GORA_QUERY_KEY_RANGE_TO, propertiesMap)) {
- query.setKeyRange(getProperty(GoraAttribute.GORA_QUERY_KEY_RANGE_FROM, propertiesMap),
- getProperty(GoraAttribute.GORA_QUERY_KEY_RANGE_TO, propertiesMap));
- }
-
- return query;
- }
-
- /**
- * Utility method to check if a value exist in the configuration class
- *
- * <b>NOTE:</> Checks only if is not null
- */
- protected static boolean configurationExist(
- final GoraAttribute attr,
- final GoraConfiguration conf)
- throws IllegalAccessException, NoSuchMethodException, InvocationTargetException {
- return PropertyUtils.getSimpleProperty(conf, attr.value) != null;
- }
-
- /**
- * Utility method to check if a value exist in the properties map
- */
- protected static boolean propertyExist(
- final GoraAttribute attr,
- final Map<String, ?> propertiesMap) {
- return propertiesMap.containsKey(attr.value);
- }
-
- /**
- * Utility method to extract value from configuration
- */
- protected static Object getAttribute(
- final GoraAttribute attr,
- final GoraConfiguration conf)
- throws IllegalAccessException, NoSuchMethodException, InvocationTargetException {
- return PropertyUtils.getSimpleProperty(conf, attr.value);
- }
-
- /**
- * Utility method to extract value from configuration as String
- */
- protected static String getAttributeAsString(
- final GoraAttribute attr,
- final GoraConfiguration conf)
- throws IllegalAccessException, NoSuchMethodException, InvocationTargetException {
- return String.valueOf(getAttribute(attr, conf));
- }
-
- /**
- * Utility method to extract value from configuration as Long
- */
- protected static Long getAttributeAsLong(
- final GoraAttribute attr,
- final GoraConfiguration conf)
- throws IllegalAccessException, NoSuchMethodException, InvocationTargetException {
- return Long.parseLong(getAttributeAsString(attr, conf));
- }
-
- /**
- * Utility method to extract value of a map
- */
- protected static Object getProperty(
- final GoraAttribute attr,
- final Map<String, ?> propertiesMap) {
- return propertiesMap.get(attr.value);
- }
-
- /**
- * Utility method to extract value of a map as String
- */
- protected static String getPropertyAsString(
- final GoraAttribute attr,
- final Map<String, ?> propertiesMap) {
- return String.valueOf(getProperty(attr, propertiesMap));
- }
-
- /**
- * Utility method to extract value of a map as long
- */
- protected static Long getPropertyAsLong(
- final GoraAttribute attr,
- final Map<String, ?> propertiesMap) {
- return Long.parseLong(getPropertyAsString(attr, propertiesMap));
- }
-
- /**
- * Utility method to extract GORA key from the exchange
- *
- * <b>NOTE:</b> key value expected to be stored in the "in" message headers.
- *
- * @param exchange The Camel Exchange
- * @return The key
- */
- public static Object getKeyFromExchange(Exchange exchange) {
- final Object key = exchange.getIn().getHeader(GoraAttribute.GORA_KEY.value);
- checkNotNull(key, "Key should not be null!");
- return key;
- }
-
- /**
- * Utility method to extract the value from the exchange
- *
- * <b>NOTE:</b> the value expected to be instance of persistent type.
- *
- * @param exchange The Camel Exchange
- * @return The value
- */
- public static Persistent getValueFromExchange(Exchange exchange) {
- return exchange.getIn().getBody(Persistent.class);
- }
-
-}
diff --git a/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraConfigurationTest.java b/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraConfigurationTest.java
deleted file mode 100644
index ef5e6592084..00000000000
--- a/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraConfigurationTest.java
+++ /dev/null
@@ -1,77 +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.gora;
-
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertThrows;
-
-/**
- * GORA Configuration Tests
- */
-public class GoraConfigurationTest {
-
- @Test
- public void setKeyClassClassShouldThrowExceptionIfNull() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(IllegalArgumentException.class,
- () -> conf.setValueClass(null));
- }
-
- @Test
- public void setKeyClassShouldThrowExceptionIfEmpty() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(IllegalArgumentException.class,
- () -> conf.setValueClass(""));
- }
-
- @Test
- public void setValueClassClassShouldThrowExceptionIfNull() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(IllegalArgumentException.class,
- () -> conf.setValueClass(null));
- }
-
- @Test
- public void setValueClassClassShouldThrowExceptionIfEmpty() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(IllegalArgumentException.class,
- () -> conf.setValueClass(""));
- }
-
- @Test
- public void setDataStoreClassShouldThrowExceptionIfNull() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(IllegalArgumentException.class,
- () -> conf.setDataStoreClass(null));
- }
-
- @Test
- public void setDataStoreClassShouldThrowExceptionIfEmpty() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(IllegalArgumentException.class,
- () -> conf.setDataStoreClass(""));
- }
-
- @Test
- public void setHadoopConfigurationShouldThrowExceptionIfNull() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(NullPointerException.class,
- () -> conf.setHadoopConfiguration(null));
- }
-
-}
diff --git a/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraProducerTest.java b/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraProducerTest.java
deleted file mode 100644
index 75ed13426ef..00000000000
--- a/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraProducerTest.java
+++ /dev/null
@@ -1,235 +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.gora;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.gora.persistency.Persistent;
-import org.apache.gora.store.DataStore;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.extension.ExtendWith;
-import org.mockito.Mock;
-import org.mockito.junit.jupiter.MockitoExtension;
-
-import static org.junit.jupiter.api.Assertions.assertThrows;
-import static org.mockito.Mockito.atLeastOnce;
-import static org.mockito.Mockito.atMost;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
-
-/**
- * GORA Producer Tests
- */
-@ExtendWith(MockitoExtension.class)
-public class GoraProducerTest extends GoraTestSupport {
-
- // TODO: Query methods does not yet has tests
-
- /**
- * Mock CamelExchange
- */
- @Mock
- private Exchange mockCamelExchange;
-
- /**
- * Mock Gora Endpoint
- */
- @Mock
- private GoraEndpoint mockGoraEndpoint;
-
- /**
- * Mock Gora Configuration
- */
- @Mock
- private GoraConfiguration mockGoraConfiguration;
-
- /**
- * Mock Camel Message
- */
- @Mock
- private Message mockCamelMessage;
-
- /**
- * Mock Gora DataStore
- */
- @Mock
- private DataStore<Object, Persistent> mockDatastore;
-
- @Override
- @BeforeEach
- public void setUp() {
- //setup mocks
- mockCamelExchange = mock(Exchange.class);
- mockGoraEndpoint = mock(GoraEndpoint.class);
- mockGoraConfiguration = mock(GoraConfiguration.class);
- mockCamelMessage = mock(Message.class);
-
- //setup default conditions
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- }
-
- @Test
- public void processShouldThrowExceptionIfOperationIsNull() {
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- assertThrows(RuntimeException.class,
- () -> producer.process(mockCamelExchange));
- }
-
- @Test
- public void shouldThrowExceptionIfOperationIsUnknown() {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("dah");
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- assertThrows(RuntimeException.class,
- () -> producer.process(mockCamelExchange));
-
- verify(mockCamelExchange, atMost(1)).getIn();
- verify(mockCamelMessage, atMost(1)).getHeader(GoraAttribute.GORA_OPERATION.value);
- }
-
- @Test
- public void shouldInvokeDastorePut() throws Exception {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("PUT");
-
- final Long sampleKey = 2L;
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_KEY.value)).thenReturn(sampleKey);
-
- final Persistent sampleValue = mock(Persistent.class);
- when(mockCamelMessage.getBody(Persistent.class)).thenReturn(sampleValue);
-
- final Message outMessage = mock(Message.class);
- when(mockCamelExchange.getMessage()).thenReturn(outMessage);
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- producer.process(mockCamelExchange);
-
- verify(mockCamelExchange, atLeastOnce()).getIn();
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_OPERATION.value);
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_KEY.value);
- verify(mockCamelMessage, atLeastOnce()).getBody(Persistent.class);
- verify(mockDatastore, atMost(1)).put(sampleKey, sampleValue);
- }
-
- @Test
- public void shouldInvokeDastoreGet() throws Exception {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("get");
-
- final Long sampleKey = 2L;
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_KEY.value)).thenReturn(sampleKey);
-
- final Message outMessage = mock(Message.class);
- when(mockCamelExchange.getMessage()).thenReturn(outMessage);
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- producer.process(mockCamelExchange);
-
- verify(mockCamelExchange, atLeastOnce()).getIn();
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_OPERATION.value);
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_KEY.value);
- verify(mockDatastore, atMost(1)).get(sampleKey);
- }
-
- @Test
- public void shouldInvokeDatastoreDelete() throws Exception {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("dEletE");
-
- final Long sampleKey = 2L;
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_KEY.value)).thenReturn(sampleKey);
-
- final Message outMessage = mock(Message.class);
- when(mockCamelExchange.getMessage()).thenReturn(outMessage);
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- producer.process(mockCamelExchange);
-
- verify(mockCamelExchange, atLeastOnce()).getIn();
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_OPERATION.value);
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_KEY.value);
- verify(mockDatastore, atMost(1)).delete(sampleKey);
- }
-
- @Test
- public void shouldInvokeDastoreSchemaExists() throws Exception {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("schemaExists");
-
- final Message outMessage = mock(Message.class);
- when(mockCamelExchange.getMessage()).thenReturn(outMessage);
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- producer.process(mockCamelExchange);
-
- verify(mockCamelExchange, atLeastOnce()).getIn();
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_OPERATION.value);
- verify(mockDatastore, atMost(1)).schemaExists();
- }
-
- @Test
- public void shouldInvokeDastoreCreateSchema() throws Exception {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("createSchema");
-
- final Message outMessage = mock(Message.class);
- when(mockCamelExchange.getMessage()).thenReturn(outMessage);
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- producer.process(mockCamelExchange);
-
- verify(mockCamelExchange, atLeastOnce()).getIn();
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_OPERATION.value);
- verify(mockDatastore, atMost(1)).createSchema();
- }
-
- @Test
- public void shouldInvokeDastoreGetSchemaName() throws Exception {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("GetSchemANamE");
-
- final Message outMessage = mock(Message.class);
- when(mockCamelExchange.getMessage()).thenReturn(outMessage);
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- producer.process(mockCamelExchange);
-
- verify(mockCamelExchange, atLeastOnce()).getIn();
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_OPERATION.value);
- verify(mockDatastore, atMost(1)).getSchemaName();
- }
-
- @Test
- public void shouldInvokeDatastoreDeleteSchema() throws Exception {
- when(mockCamelExchange.getIn()).thenReturn(mockCamelMessage);
- when(mockCamelMessage.getHeader(GoraAttribute.GORA_OPERATION.value)).thenReturn("DeleteSChEmA");
-
- final Message outMessage = mock(Message.class);
- when(mockCamelExchange.getMessage()).thenReturn(outMessage);
-
- final GoraProducer producer = new GoraProducer(mockGoraEndpoint, mockGoraConfiguration, mockDatastore);
- producer.process(mockCamelExchange);
-
- verify(mockCamelExchange, atLeastOnce()).getIn();
- verify(mockCamelMessage, atLeastOnce()).getHeader(GoraAttribute.GORA_OPERATION.value);
- verify(mockDatastore, atMost(1)).deleteSchema();
- }
-
-}
diff --git a/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraTestSupport.java b/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraTestSupport.java
deleted file mode 100644
index 4c719832cf8..00000000000
--- a/components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraTestSupport.java
+++ /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.
- */
-package org.apache.camel.component.gora;
-
-import org.apache.camel.test.junit5.CamelTestSupport;
-
-/**
- * GORA Test Support
- *
- */
-public class GoraTestSupport extends CamelTestSupport {
-
- // currently empty
-}
diff --git a/components/camel-gora/src/test/java/org/apache/camel/component/gora/utils/GoraUtilsTest.java b/components/camel-gora/src/test/java/org/apache/camel/component/gora/utils/GoraUtilsTest.java
deleted file mode 100644
index 3a8fad5ee25..00000000000
--- a/components/camel-gora/src/test/java/org/apache/camel/component/gora/utils/GoraUtilsTest.java
+++ /dev/null
@@ -1,51 +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.gora.utils;
-
-import org.apache.camel.component.gora.GoraAttribute;
-import org.apache.camel.component.gora.GoraConfiguration;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertThrows;
-import static org.junit.jupiter.api.Assertions.assertTrue;
-
-/**
- * GORA Utils Tests
- */
-public class GoraUtilsTest {
-
- @Test
- public void configurationExistShouldSucceedtIfMethodExist() throws Exception {
- final GoraConfiguration conf = new GoraConfiguration();
- assertTrue(GoraUtils.configurationExist(GoraAttribute.GORA_QUERY_LIMIT, conf));
- }
-
- @Test
- public void configurationExistShouldThrowExceptionIfMethodDoesNotExist() {
- final GoraConfiguration conf = new GoraConfiguration();
- assertThrows(NoSuchMethodException.class,
- () -> GoraUtils.configurationExist(GoraAttribute.GORA_KEY, conf));
- }
-
- @Test
- public void getAttributeAsLongShouldSReturnTheCorrectValue() throws Exception {
- final GoraConfiguration conf = new GoraConfiguration();
- conf.setLimit(3L);
- assertEquals(Long.valueOf(3), GoraUtils.getAttributeAsLong(GoraAttribute.GORA_QUERY_LIMIT, conf));
- }
-}
diff --git a/components/camel-gora/src/test/resources/log4j2.properties b/components/camel-gora/src/test/resources/log4j2.properties
deleted file mode 100644
index 20fd3b914b2..00000000000
--- a/components/camel-gora/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-gora-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/pom.xml b/components/pom.xml
index af2e90dd71d..c7071d94f3e 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -143,7 +143,6 @@
<module>camel-git</module>
<module>camel-github</module>
<module>camel-google</module>
- <module>camel-gora</module>
<module>camel-grape</module>
<module>camel-graphql</module>
<module>camel-grok</module>
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 3266d2f1150..3fadd2962d3 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
@@ -115,7 +115,6 @@ google-secret-manager
google-sheets
google-sheets-stream
google-storage
-gora
grape
graphql
grpc
diff --git a/docs/components/modules/ROOT/examples/json/gora.json b/docs/components/modules/ROOT/examples/json/gora.json
deleted file mode 120000
index fe915c8a7ca..00000000000
--- a/docs/components/modules/ROOT/examples/json/gora.json
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../../components/camel-gora/src/generated/resources/org/apache/camel/component/gora/gora.json
\ No newline at end of file
diff --git a/docs/components/modules/ROOT/nav.adoc b/docs/components/modules/ROOT/nav.adoc
index 60b3dc9fcd7..f7b05f48ba8 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -120,7 +120,6 @@
*** xref:google-sheets-component.adoc[Google Sheets]
*** xref:google-sheets-stream-component.adoc[Google Sheets Stream]
*** xref:google-storage-component.adoc[Google Storage]
-** xref:gora-component.adoc[Gora]
** xref:grape-component.adoc[Grape]
** xref:graphql-component.adoc[GraphQL]
** xref:grpc-component.adoc[gRPC]
diff --git a/docs/components/modules/ROOT/pages/gora-component.adoc b/docs/components/modules/ROOT/pages/gora-component.adoc
deleted file mode 120000
index 00dd07f3d0f..00000000000
--- a/docs/components/modules/ROOT/pages/gora-component.adoc
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../components/camel-gora/src/main/docs/gora-component.adoc
\ No newline at end of file
diff --git a/docs/user-manual/modules/ROOT/pages/camel-4-migration-guide.adoc b/docs/user-manual/modules/ROOT/pages/camel-4-migration-guide.adoc
index 476290890f1..45f4b6839a9 100644
--- a/docs/user-manual/modules/ROOT/pages/camel-4-migration-guide.adoc
+++ b/docs/user-manual/modules/ROOT/pages/camel-4-migration-guide.adoc
@@ -17,6 +17,7 @@ The following components has been removed:
- camel-caffeine-lrucache
- camel-cdi
- camel-elasticsearch-rest
+- camel-gora
- camel-hbase
- camel-iota
- camel-ipfs
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 2cad6df48ba..07a2b23d2f0 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
@@ -1596,19 +1596,6 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.GoogleStorageComponentBuilderFactory.GoogleStorageComponentBuilder googleStorage() {
return org.apache.camel.builder.component.dsl.GoogleStorageComponentBuilderFactory.googleStorage();
}
- /**
- * Gora (camel-gora)
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Category: database,nosql,bigdata
- * Since: 2.14
- * Maven coordinates: org.apache.camel:camel-gora
- *
- * @return the dsl builder
- */
- static org.apache.camel.builder.component.dsl.GoraComponentBuilderFactory.GoraComponentBuilder gora() {
- return org.apache.camel.builder.component.dsl.GoraComponentBuilderFactory.gora();
- }
/**
* Grape (camel-grape)
* Fetch, load and manage additional jars dynamically after Camel Context
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GoraComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GoraComponentBuilderFactory.java
deleted file mode 100644
index ebfb08a50f1..00000000000
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/GoraComponentBuilderFactory.java
+++ /dev/null
@@ -1,140 +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.gora.GoraComponent;
-
-/**
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface GoraComponentBuilderFactory {
-
- /**
- * Gora (camel-gora)
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Category: database,nosql,bigdata
- * Since: 2.14
- * Maven coordinates: org.apache.camel:camel-gora
- *
- * @return the dsl builder
- */
- static GoraComponentBuilder gora() {
- return new GoraComponentBuilderImpl();
- }
-
- /**
- * Builder for the Gora component.
- */
- interface GoraComponentBuilder extends ComponentBuilder<GoraComponent> {
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions occurred while the consumer is trying to
- * pickup incoming messages, or the likes, will now be processed as a
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default GoraComponentBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- 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 is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: producer
- *
- * @param lazyStartProducer the value to set
- * @return the dsl builder
- */
- default GoraComponentBuilder lazyStartProducer(boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- 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 GoraComponentBuilder autowiredEnabled(boolean autowiredEnabled) {
- doSetProperty("autowiredEnabled", autowiredEnabled);
- return this;
- }
- }
-
- class GoraComponentBuilderImpl
- extends
- AbstractComponentBuilder<GoraComponent>
- implements
- GoraComponentBuilder {
- @Override
- protected GoraComponent buildConcreteComponent() {
- return new GoraComponent();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "bridgeErrorHandler": ((GoraComponent) component).setBridgeErrorHandler((boolean) value); return true;
- case "lazyStartProducer": ((GoraComponent) component).setLazyStartProducer((boolean) value); return true;
- case "autowiredEnabled": ((GoraComponent) component).setAutowiredEnabled((boolean) 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 2f020fa0086..2ff12589f9d 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -2597,28 +2597,6 @@
"producerOnly": false,
"lenientProperties": false
},
- "GoraComponentBuilderFactory": {
- "kind": "component",
- "name": "gora",
- "title": "Gora",
- "description": "Access NoSQL databases using the Apache Gora framework.",
- "deprecated": false,
- "firstVersion": "2.14.0",
- "label": "database,nosql,bigdata",
- "javaType": "org.apache.camel.component.gora.GoraComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-gora",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "gora",
- "extendsScheme": "",
- "syntax": "gora:name",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
"GrapeComponentBuilderFactory": {
"kind": "component",
"name": "grape",
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 0d4805ebd06..b8685730f97 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
@@ -132,7 +132,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.GoogleSecretManagerEndpointBuilderFactory.GoogleSecretManagerBuilders,
org.apache.camel.builder.endpoint.dsl.GoogleSheetsEndpointBuilderFactory.GoogleSheetsBuilders,
org.apache.camel.builder.endpoint.dsl.GoogleSheetsStreamEndpointBuilderFactory.GoogleSheetsStreamBuilders,
- org.apache.camel.builder.endpoint.dsl.GoraEndpointBuilderFactory.GoraBuilders,
org.apache.camel.builder.endpoint.dsl.GrapeEndpointBuilderFactory.GrapeBuilders,
org.apache.camel.builder.endpoint.dsl.GraphqlEndpointBuilderFactory.GraphqlBuilders,
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory.GridFsBuilders,
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 55670367387..55139dc09bc 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
@@ -129,7 +129,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.GoogleSecretManagerEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GoogleSheetsEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GoogleSheetsStreamEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.GoraEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GrapeEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GraphqlEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.GridFsEndpointBuilderFactory,
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 4a9ccba8cc3..4bd4f50fd67 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
@@ -5478,49 +5478,6 @@ public class StaticEndpointBuilders {
String path) {
return org.apache.camel.builder.endpoint.dsl.GoogleCloudStorageEndpointBuilderFactory.endpointBuilder(componentName, path);
}
- /**
- * Gora (camel-gora)
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Category: database,nosql,bigdata
- * Since: 2.14
- * Maven coordinates: org.apache.camel:camel-gora
- *
- * Syntax: <code>gora:name</code>
- *
- * Path parameter: name (required)
- * Instance name
- *
- * @param path name
- * @return the dsl builder
- */
- public static org.apache.camel.builder.endpoint.dsl.GoraEndpointBuilderFactory.GoraEndpointBuilder gora(
- String path) {
- return org.apache.camel.builder.endpoint.dsl.GoraEndpointBuilderFactory.endpointBuilder("gora", path);
- }
- /**
- * Gora (camel-gora)
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Category: database,nosql,bigdata
- * Since: 2.14
- * Maven coordinates: org.apache.camel:camel-gora
- *
- * Syntax: <code>gora:name</code>
- *
- * Path parameter: name (required)
- * Instance name
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path name
- * @return the dsl builder
- */
- public static org.apache.camel.builder.endpoint.dsl.GoraEndpointBuilderFactory.GoraEndpointBuilder gora(
- String componentName,
- String path) {
- return org.apache.camel.builder.endpoint.dsl.GoraEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
/**
* Grape (camel-grape)
* Fetch, load and manage additional jars dynamically after Camel Context
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GoraEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GoraEndpointBuilderFactory.java
deleted file mode 100644
index 49a2cab9337..00000000000
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GoraEndpointBuilderFactory.java
+++ /dev/null
@@ -1,971 +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;
-
-/**
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface GoraEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint consumers for the Gora component.
- */
- public interface GoraEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default AdvancedGoraEndpointConsumerBuilder advanced() {
- return (AdvancedGoraEndpointConsumerBuilder) this;
- }
- /**
- * The type of the dataStore.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param dataStoreClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder dataStoreClass(String dataStoreClass) {
- doSetProperty("dataStoreClass", dataStoreClass);
- return this;
- }
- /**
- * The type class of the key.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param keyClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder keyClass(String keyClass) {
- doSetProperty("keyClass", keyClass);
- return this;
- }
- /**
- * The type of the value.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param valueClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder valueClass(String valueClass) {
- doSetProperty("valueClass", valueClass);
- return this;
- }
- /**
- * Number of concurrent consumers.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 1
- * Group: consumer
- *
- * @param concurrentConsumers the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder concurrentConsumers(
- int concurrentConsumers) {
- doSetProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * Number of concurrent consumers.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 1
- * Group: consumer
- *
- * @param concurrentConsumers the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder concurrentConsumers(
- String concurrentConsumers) {
- doSetProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * The End Key.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param endKey the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder endKey(Object endKey) {
- doSetProperty("endKey", endKey);
- return this;
- }
- /**
- * The End Key.
- *
- * The option will be converted to a
- * <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param endKey the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder endKey(String endKey) {
- doSetProperty("endKey", endKey);
- return this;
- }
- /**
- * The End Time.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- *
- * @param endTime the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder endTime(long endTime) {
- doSetProperty("endTime", endTime);
- return this;
- }
- /**
- * The End Time.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- *
- * @param endTime the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder endTime(String endTime) {
- doSetProperty("endTime", endTime);
- return this;
- }
- /**
- * The Fields.
- *
- * The option is a:
- * <code>com.google.common.base.Strings</code> type.
- *
- * Group: consumer
- *
- * @param fields the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder fields(
- com.google.common.base.Strings fields) {
- doSetProperty("fields", fields);
- return this;
- }
- /**
- * The Fields.
- *
- * The option will be converted to a
- * <code>com.google.common.base.Strings</code> type.
- *
- * Group: consumer
- *
- * @param fields the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder fields(String fields) {
- doSetProperty("fields", fields);
- return this;
- }
- /**
- * The Key Range From.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param keyRangeFrom the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder keyRangeFrom(Object keyRangeFrom) {
- doSetProperty("keyRangeFrom", keyRangeFrom);
- return this;
- }
- /**
- * The Key Range From.
- *
- * The option will be converted to a
- * <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param keyRangeFrom the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder keyRangeFrom(String keyRangeFrom) {
- doSetProperty("keyRangeFrom", keyRangeFrom);
- return this;
- }
- /**
- * The Key Range To.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param keyRangeTo the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder keyRangeTo(Object keyRangeTo) {
- doSetProperty("keyRangeTo", keyRangeTo);
- return this;
- }
- /**
- * The Key Range To.
- *
- * The option will be converted to a
- * <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param keyRangeTo the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder keyRangeTo(String keyRangeTo) {
- doSetProperty("keyRangeTo", keyRangeTo);
- return this;
- }
- /**
- * The Limit.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- *
- * @param limit the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder limit(long limit) {
- doSetProperty("limit", limit);
- return this;
- }
- /**
- * The Limit.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- *
- * @param limit the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder limit(String limit) {
- doSetProperty("limit", limit);
- return this;
- }
- /**
- * The Start Key.
- *
- * The option is a: <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param startKey the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder startKey(Object startKey) {
- doSetProperty("startKey", startKey);
- return this;
- }
- /**
- * The Start Key.
- *
- * The option will be converted to a
- * <code>java.lang.Object</code> type.
- *
- * Group: consumer
- *
- * @param startKey the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder startKey(String startKey) {
- doSetProperty("startKey", startKey);
- return this;
- }
- /**
- * The Start Time.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- *
- * @param startTime the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder startTime(long startTime) {
- doSetProperty("startTime", startTime);
- return this;
- }
- /**
- * The Start Time.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- *
- * @param startTime the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder startTime(String startTime) {
- doSetProperty("startTime", startTime);
- return this;
- }
- /**
- * The Time Range From.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- *
- * @param timeRangeFrom the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder timeRangeFrom(long timeRangeFrom) {
- doSetProperty("timeRangeFrom", timeRangeFrom);
- return this;
- }
- /**
- * The Time Range From.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- *
- * @param timeRangeFrom the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder timeRangeFrom(String timeRangeFrom) {
- doSetProperty("timeRangeFrom", timeRangeFrom);
- return this;
- }
- /**
- * The Time Range To.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- *
- * @param timeRangeTo the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder timeRangeTo(long timeRangeTo) {
- doSetProperty("timeRangeTo", timeRangeTo);
- return this;
- }
- /**
- * The Time Range To.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- *
- * @param timeRangeTo the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder timeRangeTo(String timeRangeTo) {
- doSetProperty("timeRangeTo", timeRangeTo);
- return this;
- }
- /**
- * The Timestamp.
- *
- * The option is a: <code>long</code> type.
- *
- * Group: consumer
- *
- * @param timestamp the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder timestamp(long timestamp) {
- doSetProperty("timestamp", timestamp);
- return this;
- }
- /**
- * The Timestamp.
- *
- * The option will be converted to a <code>long</code> type.
- *
- * Group: consumer
- *
- * @param timestamp the value to set
- * @return the dsl builder
- */
- default GoraEndpointConsumerBuilder timestamp(String timestamp) {
- doSetProperty("timestamp", timestamp);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint consumers for the Gora component.
- */
- public interface AdvancedGoraEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default GoraEndpointConsumerBuilder basic() {
- return (GoraEndpointConsumerBuilder) this;
- }
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions occurred while the consumer is trying to
- * pickup incoming messages, or the likes, will now be processed as a
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer (advanced)
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * Allows for bridging the consumer to the Camel routing Error Handler,
- * which mean any exceptions occurred while the consumer is trying to
- * pickup incoming messages, or the likes, will now be processed as a
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: consumer (advanced)
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * To let the consumer use a custom ExceptionHandler. Notice if the
- * option bridgeErrorHandler is enabled then this option is not in use.
- * By default the consumer will deal with exceptions, that will be
- * logged at WARN or ERROR level and ignored.
- *
- * The option is a:
- * <code>org.apache.camel.spi.ExceptionHandler</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exceptionHandler the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder exceptionHandler(
- org.apache.camel.spi.ExceptionHandler exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * To let the consumer use a custom ExceptionHandler. Notice if the
- * option bridgeErrorHandler is enabled then this option is not in use.
- * By default the consumer will deal with exceptions, that will be
- * logged at WARN or ERROR level and ignored.
- *
- * The option will be converted to a
- * <code>org.apache.camel.spi.ExceptionHandler</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exceptionHandler the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder exceptionHandler(
- String exceptionHandler) {
- doSetProperty("exceptionHandler", exceptionHandler);
- return this;
- }
- /**
- * Sets the exchange pattern when the consumer creates an exchange.
- *
- * The option is a:
- * <code>org.apache.camel.ExchangePattern</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exchangePattern the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder exchangePattern(
- org.apache.camel.ExchangePattern exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- /**
- * Sets the exchange pattern when the consumer creates an exchange.
- *
- * The option will be converted to a
- * <code>org.apache.camel.ExchangePattern</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param exchangePattern the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder exchangePattern(
- String exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- /**
- * Hadoop Configuration.
- *
- * The option is a:
- * <code>org.apache.hadoop.conf.Configuration</code> type.
- *
- * Group: advanced
- *
- * @param hadoopConfiguration the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder hadoopConfiguration(
- org.apache.hadoop.conf.Configuration hadoopConfiguration) {
- doSetProperty("hadoopConfiguration", hadoopConfiguration);
- return this;
- }
- /**
- * Hadoop Configuration.
- *
- * The option will be converted to a
- * <code>org.apache.hadoop.conf.Configuration</code> type.
- *
- * Group: advanced
- *
- * @param hadoopConfiguration the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointConsumerBuilder hadoopConfiguration(
- String hadoopConfiguration) {
- doSetProperty("hadoopConfiguration", hadoopConfiguration);
- return this;
- }
- }
-
- /**
- * Builder for endpoint producers for the Gora component.
- */
- public interface GoraEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedGoraEndpointProducerBuilder advanced() {
- return (AdvancedGoraEndpointProducerBuilder) this;
- }
- /**
- * The type of the dataStore.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param dataStoreClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointProducerBuilder dataStoreClass(String dataStoreClass) {
- doSetProperty("dataStoreClass", dataStoreClass);
- return this;
- }
- /**
- * The type class of the key.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param keyClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointProducerBuilder keyClass(String keyClass) {
- doSetProperty("keyClass", keyClass);
- return this;
- }
- /**
- * The type of the value.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param valueClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointProducerBuilder valueClass(String valueClass) {
- doSetProperty("valueClass", valueClass);
- return this;
- }
- /**
- * Flush on every operation.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: producer
- *
- * @param flushOnEveryOperation the value to set
- * @return the dsl builder
- */
- default GoraEndpointProducerBuilder flushOnEveryOperation(
- boolean flushOnEveryOperation) {
- doSetProperty("flushOnEveryOperation", flushOnEveryOperation);
- return this;
- }
- /**
- * Flush on every operation.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: producer
- *
- * @param flushOnEveryOperation the value to set
- * @return the dsl builder
- */
- default GoraEndpointProducerBuilder flushOnEveryOperation(
- String flushOnEveryOperation) {
- doSetProperty("flushOnEveryOperation", flushOnEveryOperation);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint producers for the Gora component.
- */
- public interface AdvancedGoraEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default GoraEndpointProducerBuilder basic() {
- return (GoraEndpointProducerBuilder) 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 AdvancedGoraEndpointProducerBuilder 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 AdvancedGoraEndpointProducerBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * Hadoop Configuration.
- *
- * The option is a:
- * <code>org.apache.hadoop.conf.Configuration</code> type.
- *
- * Group: advanced
- *
- * @param hadoopConfiguration the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointProducerBuilder hadoopConfiguration(
- org.apache.hadoop.conf.Configuration hadoopConfiguration) {
- doSetProperty("hadoopConfiguration", hadoopConfiguration);
- return this;
- }
- /**
- * Hadoop Configuration.
- *
- * The option will be converted to a
- * <code>org.apache.hadoop.conf.Configuration</code> type.
- *
- * Group: advanced
- *
- * @param hadoopConfiguration the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointProducerBuilder hadoopConfiguration(
- String hadoopConfiguration) {
- doSetProperty("hadoopConfiguration", hadoopConfiguration);
- return this;
- }
- }
-
- /**
- * Builder for endpoint for the Gora component.
- */
- public interface GoraEndpointBuilder
- extends
- GoraEndpointConsumerBuilder,
- GoraEndpointProducerBuilder {
- default AdvancedGoraEndpointBuilder advanced() {
- return (AdvancedGoraEndpointBuilder) this;
- }
- /**
- * The type of the dataStore.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param dataStoreClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointBuilder dataStoreClass(String dataStoreClass) {
- doSetProperty("dataStoreClass", dataStoreClass);
- return this;
- }
- /**
- * The type class of the key.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param keyClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointBuilder keyClass(String keyClass) {
- doSetProperty("keyClass", keyClass);
- return this;
- }
- /**
- * The type of the value.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param valueClass the value to set
- * @return the dsl builder
- */
- default GoraEndpointBuilder valueClass(String valueClass) {
- doSetProperty("valueClass", valueClass);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the Gora component.
- */
- public interface AdvancedGoraEndpointBuilder
- extends
- AdvancedGoraEndpointConsumerBuilder,
- AdvancedGoraEndpointProducerBuilder {
- default GoraEndpointBuilder basic() {
- return (GoraEndpointBuilder) this;
- }
- /**
- * Hadoop Configuration.
- *
- * The option is a:
- * <code>org.apache.hadoop.conf.Configuration</code> type.
- *
- * Group: advanced
- *
- * @param hadoopConfiguration the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointBuilder hadoopConfiguration(
- org.apache.hadoop.conf.Configuration hadoopConfiguration) {
- doSetProperty("hadoopConfiguration", hadoopConfiguration);
- return this;
- }
- /**
- * Hadoop Configuration.
- *
- * The option will be converted to a
- * <code>org.apache.hadoop.conf.Configuration</code> type.
- *
- * Group: advanced
- *
- * @param hadoopConfiguration the value to set
- * @return the dsl builder
- */
- default AdvancedGoraEndpointBuilder hadoopConfiguration(
- String hadoopConfiguration) {
- doSetProperty("hadoopConfiguration", hadoopConfiguration);
- return this;
- }
- }
-
- public interface GoraBuilders {
- /**
- * Gora (camel-gora)
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Category: database,nosql,bigdata
- * Since: 2.14
- * Maven coordinates: org.apache.camel:camel-gora
- *
- * @return the dsl builder for the headers' name.
- */
- default GoraHeaderNameBuilder gora() {
- return GoraHeaderNameBuilder.INSTANCE;
- }
- /**
- * Gora (camel-gora)
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Category: database,nosql,bigdata
- * Since: 2.14
- * Maven coordinates: org.apache.camel:camel-gora
- *
- * Syntax: <code>gora:name</code>
- *
- * Path parameter: name (required)
- * Instance name
- *
- * @param path name
- * @return the dsl builder
- */
- default GoraEndpointBuilder gora(String path) {
- return GoraEndpointBuilderFactory.endpointBuilder("gora", path);
- }
- /**
- * Gora (camel-gora)
- * Access NoSQL databases using the Apache Gora framework.
- *
- * Category: database,nosql,bigdata
- * Since: 2.14
- * Maven coordinates: org.apache.camel:camel-gora
- *
- * Syntax: <code>gora:name</code>
- *
- * Path parameter: name (required)
- * Instance name
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path name
- * @return the dsl builder
- */
- default GoraEndpointBuilder gora(String componentName, String path) {
- return GoraEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
-
- /**
- * The builder of headers' name for the Gora component.
- */
- public static class GoraHeaderNameBuilder {
- /**
- * The internal instance of the builder used to access to all the
- * methods representing the name of headers.
- */
- private static final GoraHeaderNameBuilder INSTANCE = new GoraHeaderNameBuilder();
-
- /**
- * Used in order to define the datum key for the operations need it.
- *
- * The option is a: {@code Object} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code goraKey}.
- */
- public String goraKey() {
- return "goraKey";
- }
-
- /**
- * Used in order to define the operation to execute.
- *
- * The option is a: {@code String} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code goraOperation}.
- */
- public String goraOperation() {
- return "goraOperation";
- }
- }
- static GoraEndpointBuilder endpointBuilder(String componentName, String path) {
- class GoraEndpointBuilderImpl extends AbstractEndpointBuilder implements GoraEndpointBuilder, AdvancedGoraEndpointBuilder {
- public GoraEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new GoraEndpointBuilderImpl(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 2874cb562f8..38568d7126c 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
@@ -132,7 +132,6 @@ org.apache.camel.component.google.secret.manager.GoogleSecretManagerComponent=ca
org.apache.camel.component.google.sheets.GoogleSheetsComponent=camel:google-sheets
org.apache.camel.component.google.sheets.stream.GoogleSheetsStreamComponent=camel:google-sheets
org.apache.camel.component.google.storage.GoogleCloudStorageComponent=camel:google-storage
-org.apache.camel.component.gora.GoraComponent=camel:gora
org.apache.camel.component.grape.GrapeComponent=camel:grape
org.apache.camel.component.graphql.GraphqlComponent=camel:graphql
org.apache.camel.component.grpc.GrpcComponent=camel:grpc
diff --git a/parent/pom.xml b/parent/pom.xml
index 23736b28ba9..ca5832cdac3 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -55,7 +55,6 @@
<apacheds-version>2.0.0.AM26</apacheds-version>
<apache-any23-version>2.7</apache-any23-version>
<apache-drill-version>1.19.0</apache-drill-version>
- <apache-gora-version>0.9</apache-gora-version>
<apicurio-version>1.1.26</apicurio-version>
<arangodb-java-version>6.20.0</arangodb-java-version>
<aries-blueprint-api-version>1.0.1</aries-blueprint-api-version>
@@ -1338,11 +1337,6 @@
<artifactId>camel-google-storage</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-gora</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-grape</artifactId>