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/07/27 13:47:47 UTC
[camel] 01/01: CAMEL-19654: Remove camel-corda component
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch corda
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 9aea3b89599e261a0dc84b577b30677fd15d551a
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Jul 27 15:47:33 2023 +0200
CAMEL-19654: Remove camel-corda component
---
bom/camel-bom/pom.xml | 5 -
catalog/camel-allcomponents/pom.xml | 5 -
.../org/apache/camel/catalog/components.properties | 1 -
.../org/apache/camel/catalog/components/corda.json | 68 --
components/camel-corda/.gitignore | 6 -
components/camel-corda/pom.xml | 87 ---
.../component/corda/CordaComponentConfigurer.java | 130 ----
.../component/corda/CordaEndpointConfigurer.java | 126 ----
.../component/corda/CordaEndpointUriFactory.java | 85 ---
.../corda/CordaProducerInvokeOnHeaderFactory.java | 100 ---
.../services/org/apache/camel/component.properties | 7 -
.../services/org/apache/camel/component/corda | 2 -
.../org/apache/camel/configurer/corda-component | 2 -
.../org/apache/camel/configurer/corda-endpoint | 2 -
.../org.apache.camel.component.corda.CordaProducer | 2 -
.../org/apache/camel/urifactory/corda-endpoint | 2 -
.../org/apache/camel/component/corda/corda.json | 68 --
.../camel-corda/src/main/docs/corda-component.adoc | 77 --
.../camel/component/corda/CordaComponent.java | 55 --
.../camel/component/corda/CordaConfiguration.java | 204 -----
.../camel/component/corda/CordaConstants.java | 97 ---
.../camel/component/corda/CordaConsumer.java | 262 -------
.../camel/component/corda/CordaEndpoint.java | 86 ---
.../camel/component/corda/CordaProducer.java | 295 --------
.../apache/camel/component/corda/CamelFlow.java | 32 -
.../component/corda/CordaConsumerITSupport.java | 74 --
.../corda/CordaConsumerNetworkMapFeedManualIT.java | 48 --
...rdaConsumerStartTrackedFlowDynamicManualIT.java | 53 --
.../CordaConsumerStateMachineFeedManualIT.java | 48 --
.../CordaConsumerTransactionMapFeedManualIT.java | 48 --
.../CordaConsumerVaultTrackByCriteriaManualIT.java | 50 --
.../corda/CordaConsumerVaultTrackByManualIT.java | 52 --
...ConsumerVaultTrackByWithPagingSpecManualIT.java | 51 --
...rdaConsumerVaultTrackByWithSortingManualIT.java | 51 --
.../corda/CordaConsumerVaultTrackManualIT.java | 49 --
.../camel/component/corda/CordaITSupport.java | 67 --
.../component/corda/CordaProducerManualIT.java | 472 ------------
.../component/corda/IntegrationWhiteList.java | 36 -
...corda.core.serialization.SerializationWhitelist | 1 -
.../src/test/resources/log4j2.properties | 34 -
.../org.mockito.plugins.MockMaker | 1 -
components/pom.xml | 1 -
.../org/apache/camel/main/components.properties | 1 -
docs/components/modules/ROOT/nav.adoc | 1 -
.../component/ComponentsBuilderFactory.java | 14 -
.../dsl/CordaComponentBuilderFactory.java | 352 ---------
.../src/generated/resources/metadata.json | 22 -
.../builder/endpoint/EndpointBuilderFactory.java | 1 -
.../camel/builder/endpoint/EndpointBuilders.java | 1 -
.../builder/endpoint/StaticEndpointBuilders.java | 45 --
.../endpoint/dsl/CordaEndpointBuilderFactory.java | 839 ---------------------
.../camel-component-known-dependencies.properties | 1 -
parent/pom.xml | 6 -
53 files changed, 4225 deletions(-)
diff --git a/bom/camel-bom/pom.xml b/bom/camel-bom/pom.xml
index 7baff1e7680..56aa1a00476 100644
--- a/bom/camel-bom/pom.xml
+++ b/bom/camel-bom/pom.xml
@@ -441,11 +441,6 @@
<artifactId>camel-controlbus</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-corda</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
diff --git a/catalog/camel-allcomponents/pom.xml b/catalog/camel-allcomponents/pom.xml
index 9254c8ccba5..be709761815 100644
--- a/catalog/camel-allcomponents/pom.xml
+++ b/catalog/camel-allcomponents/pom.xml
@@ -377,11 +377,6 @@
<artifactId>camel-controlbus</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-corda</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-couchbase</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 adb6490da35..df192153050 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
@@ -58,7 +58,6 @@ cometd
cometds
consul
controlbus
-corda
couchbase
couchdb
cql
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/corda.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/corda.json
deleted file mode 100644
index 4842424a6dd..00000000000
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/corda.json
+++ /dev/null
@@ -1,68 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "corda",
- "title": "Corda",
- "description": "Perform operations against Corda blockchain platform using corda-rpc library.",
- "deprecated": false,
- "firstVersion": "2.23.0",
- "label": "blockchain,rpc",
- "javaType": "org.apache.camel.component.corda.CordaComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-corda",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "corda",
- "extendsScheme": "",
- "syntax": "corda:node",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
- "componentProperties": {
- "configuration": { "index": 0, "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.corda.CordaConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "To use a shared configuration." },
- "bridgeErrorHandler": { "index": 1, "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 proce [...]
- "pageSpecification": { "index": 2, "kind": "property", "displayName": "Page Specification", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.PageSpecification", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200", "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "PageSpecification allows specificati [...]
- "processSnapshot": { "index": 3, "kind": "property", "displayName": "Process Snapshot", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Whether to process snapshots or not" },
- "sort": { "index": 4, "kind": "property", "displayName": "Sort", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.Sort", "enum": [ "ASC", "DESC" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Sort allows specification of a set of entity attribute names and their a [...]
- "contractStateClass": { "index": 5, "kind": "property", "displayName": "Contract State Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.contracts.ContractState>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "A contract state (or just state) [...]
- "flowLogicArguments": { "index": 6, "kind": "property", "displayName": "Flow Logic Arguments", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "array", "javaType": "java.lang.Object[]", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the given arguments, returning an Observable [...]
- "flowLogicClass": { "index": 7, "kind": "property", "displayName": "Flow Logic Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.flows.FlowLogic<java.lang.Object>>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the g [...]
- "queryCriteria": { "index": 8, "kind": "property", "displayName": "Query Criteria", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.QueryCriteria", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "QueryCriteria assumes underlying schema tables are [...]
- "lazyStartProducer": { "index": 9, "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 [...]
- "operation": { "index": 10, "kind": "property", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Operation to use" },
- "autowiredEnabled": { "index": 11, "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 [...]
- "password": { "index": 12, "kind": "property", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Password for login" },
- "username": { "index": 13, "kind": "property", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Username for login" }
- },
- "headers": {
- "OPERATION": { "index": 0, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform", "constantName": "org.apache.camel.component.corda.CordaConstants#OPERATION" },
- "ATTACHMENT_QUERY_CRITERIA": { "index": 1, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.node.services.vault.AttachmentQueryCriteria", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The attachment query criteria", "constantName": "org.apache.camel.component.corda.CordaConstants#ATTACHMENT_QUERY_CRITERIA" },
- "SORT": { "index": 2, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The sort", "constantName": "org.apache.camel.component.corda.CordaConstants#SORT" },
- "EXACT_MATCH": { "index": 3, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If true, a case sensitive match is done against each component of each X.500 name.", "constantName": "org.apache.camel.component.corda.CordaConstants#EXACT_MATCH" },
- "ARGUMENTS": { "index": 4, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Object[]", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The arguments.", "constantName": "org.apache.camel.component.corda.CordaConstants#ARGUMENTS" },
- "DRAINING_MODE": { "index": 5, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The value of the node's flows draining mode.", "constantName": "org.apache.camel.component.corda.CordaConstants#DRAINING_MODE" },
- "SECURE_HASH": { "index": 6, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.crypto.SecureHash", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Container for a cryptographically secure hash value.", "constantName": "org.apache.camel.component.corda.CordaConstants#SECURE_HASH" },
- "QUERY_CRITERIA": { "index": 7, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.node.services.vault.QueryCriteria", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The query criteria.", "constantName": "org.apache.camel.component.corda.CordaConstants#QUERY_CRITERIA" },
- "PAGE_SPECIFICATION": { "index": 8, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.node.services.vault.PageSpecification", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The PageSpecification allows specification of a page number and page size", "constantName": "org.apache.camel.component.corda.CordaConstants#PAGE_SPECIFICATION" }
- },
- "properties": {
- "node": { "index": 0, "kind": "path", "displayName": "Node", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "The url for the corda node" },
- "pageSpecification": { "index": 1, "kind": "parameter", "displayName": "Page Specification", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.PageSpecification", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200", "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "PageSpecification allows specificat [...]
- "processSnapshot": { "index": 2, "kind": "parameter", "displayName": "Process Snapshot", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Whether to process snapshots or not" },
- "sort": { "index": 3, "kind": "parameter", "displayName": "Sort", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.Sort", "enum": [ "ASC", "DESC" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Sort allows specification of a set of entity attribute names and their [...]
- "bridgeErrorHandler": { "index": 4, "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 lik [...]
- "contractStateClass": { "index": 5, "kind": "parameter", "displayName": "Contract State Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.contracts.ContractState>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "A contract state (or just state) [...]
- "exceptionHandler": { "index": 6, "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 def [...]
- "exchangePattern": { "index": 7, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "flowLogicArguments": { "index": 8, "kind": "parameter", "displayName": "Flow Logic Arguments", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "array", "javaType": "java.lang.Object[]", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the given arguments, returning an Observable [...]
- "flowLogicClass": { "index": 9, "kind": "parameter", "displayName": "Flow Logic Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.flows.FlowLogic<java.lang.Object>>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the [...]
- "queryCriteria": { "index": 10, "kind": "parameter", "displayName": "Query Criteria", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.QueryCriteria", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "QueryCriteria assumes underlying schema tables ar [...]
- "operation": { "index": 11, "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Operation to use" },
- "lazyStartProducer": { "index": 12, "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 produ [...]
- "password": { "index": 13, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Password for login" },
- "username": { "index": 14, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Username for login" }
- }
-}
diff --git a/components/camel-corda/.gitignore b/components/camel-corda/.gitignore
deleted file mode 100644
index f1ea348215c..00000000000
--- a/components/camel-corda/.gitignore
+++ /dev/null
@@ -1,6 +0,0 @@
-**/.DS_Store
-.DS_Store
-target
-.idea
-*.iml
-*.log
diff --git a/components/camel-corda/pom.xml b/components/camel-corda/pom.xml
deleted file mode 100644
index c8c5f6c0838..00000000000
--- a/components/camel-corda/pom.xml
+++ /dev/null
@@ -1,87 +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-corda</artifactId>
- <packaging>jar</packaging>
-
- <name>Camel :: Corda</name>
- <description>Camel Corda which is based on corda-rpc support</description>
-
- <dependencies>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-support</artifactId>
- </dependency>
- <dependency>
- <groupId>net.corda</groupId>
- <artifactId>corda-rpc</artifactId>
- <version>${corda-version}</version>
- <exclusions>
- <!-- corda-rpc uses log4j for logging (only need log4j-api at runtime)
- but we need to exclude log4j-core and add log4j-api as dependency -->
- <exclusion>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-core</artifactId>
- </exclusion>
- <exclusion>
- <groupId>com.google.code.findbugs</groupId>
- <artifactId>jsr305</artifactId>
- </exclusion>
- <exclusion>
- <groupId>co.paralleluniverse</groupId>
- <artifactId>quasar-core</artifactId>
- </exclusion>
- <exclusion>
- <groupId>org.hibernate</groupId>
- <artifactId>hibernate-core</artifactId>
- </exclusion>
- <exclusion>
- <groupId>org.hibernate.javax.persistence</groupId>
- <artifactId>hibernate-jpa-2.1-api</artifactId>
- </exclusion>
- </exclusions>
- </dependency>
- <dependency>
- <groupId>org.apache.logging.log4j</groupId>
- <artifactId>log4j-api</artifactId>
- </dependency>
-
- <!-- for testing -->
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-test-junit5</artifactId>
- <scope>test</scope>
- </dependency>
- <dependency>
- <groupId>org.mockito</groupId>
- <artifactId>mockito-core</artifactId>
- <version>${mockito-version}</version>
- <scope>test</scope>
- </dependency>
- </dependencies>
-</project>
diff --git a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaComponentConfigurer.java b/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaComponentConfigurer.java
deleted file mode 100644
index ebb668dd89f..00000000000
--- a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaComponentConfigurer.java
+++ /dev/null
@@ -1,130 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.corda;
-
-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 CordaComponentConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- private org.apache.camel.component.corda.CordaConfiguration getOrCreateConfiguration(CordaComponent target) {
- if (target.getConfiguration() == null) {
- target.setConfiguration(new org.apache.camel.component.corda.CordaConfiguration());
- }
- return target.getConfiguration();
- }
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- CordaComponent target = (CordaComponent) 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 "configuration": target.setConfiguration(property(camelContext, org.apache.camel.component.corda.CordaConfiguration.class, value)); return true;
- case "contractstateclass":
- case "contractStateClass": getOrCreateConfiguration(target).setContractStateClass(property(camelContext, java.lang.Class.class, value)); return true;
- case "flowlogicarguments":
- case "flowLogicArguments": getOrCreateConfiguration(target).setFlowLogicArguments(property(camelContext, java.lang.Object[].class, value)); return true;
- case "flowlogicclass":
- case "flowLogicClass": getOrCreateConfiguration(target).setFlowLogicClass(property(camelContext, java.lang.Class.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "operation": getOrCreateConfiguration(target).setOperation(property(camelContext, java.lang.String.class, value)); return true;
- case "pagespecification":
- case "pageSpecification": getOrCreateConfiguration(target).setPageSpecification(property(camelContext, net.corda.core.node.services.vault.PageSpecification.class, value)); return true;
- case "password": getOrCreateConfiguration(target).setPassword(property(camelContext, java.lang.String.class, value)); return true;
- case "processsnapshot":
- case "processSnapshot": getOrCreateConfiguration(target).setProcessSnapshot(property(camelContext, boolean.class, value)); return true;
- case "querycriteria":
- case "queryCriteria": getOrCreateConfiguration(target).setQueryCriteria(property(camelContext, net.corda.core.node.services.vault.QueryCriteria.class, value)); return true;
- case "sort": getOrCreateConfiguration(target).setSort(property(camelContext, net.corda.core.node.services.vault.Sort.class, value)); return true;
- case "username": getOrCreateConfiguration(target).setUsername(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 "autowiredenabled":
- case "autowiredEnabled": return boolean.class;
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return boolean.class;
- case "configuration": return org.apache.camel.component.corda.CordaConfiguration.class;
- case "contractstateclass":
- case "contractStateClass": return java.lang.Class.class;
- case "flowlogicarguments":
- case "flowLogicArguments": return java.lang.Object[].class;
- case "flowlogicclass":
- case "flowLogicClass": return java.lang.Class.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "operation": return java.lang.String.class;
- case "pagespecification":
- case "pageSpecification": return net.corda.core.node.services.vault.PageSpecification.class;
- case "password": return java.lang.String.class;
- case "processsnapshot":
- case "processSnapshot": return boolean.class;
- case "querycriteria":
- case "queryCriteria": return net.corda.core.node.services.vault.QueryCriteria.class;
- case "sort": return net.corda.core.node.services.vault.Sort.class;
- case "username": return java.lang.String.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- CordaComponent target = (CordaComponent) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "autowiredenabled":
- case "autowiredEnabled": return target.isAutowiredEnabled();
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "configuration": return target.getConfiguration();
- case "contractstateclass":
- case "contractStateClass": return getOrCreateConfiguration(target).getContractStateClass();
- case "flowlogicarguments":
- case "flowLogicArguments": return getOrCreateConfiguration(target).getFlowLogicArguments();
- case "flowlogicclass":
- case "flowLogicClass": return getOrCreateConfiguration(target).getFlowLogicClass();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "operation": return getOrCreateConfiguration(target).getOperation();
- case "pagespecification":
- case "pageSpecification": return getOrCreateConfiguration(target).getPageSpecification();
- case "password": return getOrCreateConfiguration(target).getPassword();
- case "processsnapshot":
- case "processSnapshot": return getOrCreateConfiguration(target).isProcessSnapshot();
- case "querycriteria":
- case "queryCriteria": return getOrCreateConfiguration(target).getQueryCriteria();
- case "sort": return getOrCreateConfiguration(target).getSort();
- case "username": return getOrCreateConfiguration(target).getUsername();
- default: return null;
- }
- }
-
- @Override
- public Object getCollectionValueType(Object target, String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "contractstateclass":
- case "contractStateClass": return net.corda.core.contracts.ContractState.class;
- case "flowlogicclass":
- case "flowLogicClass": return net.corda.core.flows.FlowLogic.class;
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaEndpointConfigurer.java b/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaEndpointConfigurer.java
deleted file mode 100644
index 83ab4d4d48d..00000000000
--- a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaEndpointConfigurer.java
+++ /dev/null
@@ -1,126 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.corda;
-
-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 CordaEndpointConfigurer extends PropertyConfigurerSupport implements GeneratedPropertyConfigurer, PropertyConfigurerGetter {
-
- @Override
- public boolean configure(CamelContext camelContext, Object obj, String name, Object value, boolean ignoreCase) {
- CordaEndpoint target = (CordaEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": target.setBridgeErrorHandler(property(camelContext, boolean.class, value)); return true;
- case "contractstateclass":
- case "contractStateClass": target.getConfiguration().setContractStateClass(property(camelContext, java.lang.Class.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 "flowlogicarguments":
- case "flowLogicArguments": target.getConfiguration().setFlowLogicArguments(property(camelContext, java.lang.Object[].class, value)); return true;
- case "flowlogicclass":
- case "flowLogicClass": target.getConfiguration().setFlowLogicClass(property(camelContext, java.lang.Class.class, value)); return true;
- case "lazystartproducer":
- case "lazyStartProducer": target.setLazyStartProducer(property(camelContext, boolean.class, value)); return true;
- case "operation": target.getConfiguration().setOperation(property(camelContext, java.lang.String.class, value)); return true;
- case "pagespecification":
- case "pageSpecification": target.getConfiguration().setPageSpecification(property(camelContext, net.corda.core.node.services.vault.PageSpecification.class, value)); return true;
- case "password": target.getConfiguration().setPassword(property(camelContext, java.lang.String.class, value)); return true;
- case "processsnapshot":
- case "processSnapshot": target.getConfiguration().setProcessSnapshot(property(camelContext, boolean.class, value)); return true;
- case "querycriteria":
- case "queryCriteria": target.getConfiguration().setQueryCriteria(property(camelContext, net.corda.core.node.services.vault.QueryCriteria.class, value)); return true;
- case "sort": target.getConfiguration().setSort(property(camelContext, net.corda.core.node.services.vault.Sort.class, value)); return true;
- case "username": target.getConfiguration().setUsername(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 "contractstateclass":
- case "contractStateClass": return java.lang.Class.class;
- case "exceptionhandler":
- case "exceptionHandler": return org.apache.camel.spi.ExceptionHandler.class;
- case "exchangepattern":
- case "exchangePattern": return org.apache.camel.ExchangePattern.class;
- case "flowlogicarguments":
- case "flowLogicArguments": return java.lang.Object[].class;
- case "flowlogicclass":
- case "flowLogicClass": return java.lang.Class.class;
- case "lazystartproducer":
- case "lazyStartProducer": return boolean.class;
- case "operation": return java.lang.String.class;
- case "pagespecification":
- case "pageSpecification": return net.corda.core.node.services.vault.PageSpecification.class;
- case "password": return java.lang.String.class;
- case "processsnapshot":
- case "processSnapshot": return boolean.class;
- case "querycriteria":
- case "queryCriteria": return net.corda.core.node.services.vault.QueryCriteria.class;
- case "sort": return net.corda.core.node.services.vault.Sort.class;
- case "username": return java.lang.String.class;
- default: return null;
- }
- }
-
- @Override
- public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
- CordaEndpoint target = (CordaEndpoint) obj;
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "bridgeerrorhandler":
- case "bridgeErrorHandler": return target.isBridgeErrorHandler();
- case "contractstateclass":
- case "contractStateClass": return target.getConfiguration().getContractStateClass();
- case "exceptionhandler":
- case "exceptionHandler": return target.getExceptionHandler();
- case "exchangepattern":
- case "exchangePattern": return target.getExchangePattern();
- case "flowlogicarguments":
- case "flowLogicArguments": return target.getConfiguration().getFlowLogicArguments();
- case "flowlogicclass":
- case "flowLogicClass": return target.getConfiguration().getFlowLogicClass();
- case "lazystartproducer":
- case "lazyStartProducer": return target.isLazyStartProducer();
- case "operation": return target.getConfiguration().getOperation();
- case "pagespecification":
- case "pageSpecification": return target.getConfiguration().getPageSpecification();
- case "password": return target.getConfiguration().getPassword();
- case "processsnapshot":
- case "processSnapshot": return target.getConfiguration().isProcessSnapshot();
- case "querycriteria":
- case "queryCriteria": return target.getConfiguration().getQueryCriteria();
- case "sort": return target.getConfiguration().getSort();
- case "username": return target.getConfiguration().getUsername();
- default: return null;
- }
- }
-
- @Override
- public Object getCollectionValueType(Object target, String name, boolean ignoreCase) {
- switch (ignoreCase ? name.toLowerCase() : name) {
- case "contractstateclass":
- case "contractStateClass": return net.corda.core.contracts.ContractState.class;
- case "flowlogicclass":
- case "flowLogicClass": return net.corda.core.flows.FlowLogic.class;
- default: return null;
- }
- }
-}
-
diff --git a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaEndpointUriFactory.java b/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaEndpointUriFactory.java
deleted file mode 100644
index 75341022e72..00000000000
--- a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaEndpointUriFactory.java
+++ /dev/null
@@ -1,85 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.corda;
-
-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 CordaEndpointUriFactory extends org.apache.camel.support.component.EndpointUriFactorySupport implements EndpointUriFactory {
-
- private static final String BASE = ":node";
-
- 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<>(15);
- props.add("bridgeErrorHandler");
- props.add("contractStateClass");
- props.add("exceptionHandler");
- props.add("exchangePattern");
- props.add("flowLogicArguments");
- props.add("flowLogicClass");
- props.add("lazyStartProducer");
- props.add("node");
- props.add("operation");
- props.add("pageSpecification");
- props.add("password");
- props.add("processSnapshot");
- props.add("queryCriteria");
- props.add("sort");
- props.add("username");
- PROPERTY_NAMES = Collections.unmodifiableSet(props);
- Set<String> secretProps = new HashSet<>(2);
- secretProps.add("password");
- secretProps.add("username");
- SECRET_PROPERTY_NAMES = Collections.unmodifiableSet(secretProps);
- MULTI_VALUE_PREFIXES = Collections.emptySet();
- }
-
- @Override
- public boolean isEnabled(String scheme) {
- return "corda".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, "node", 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-corda/src/generated/java/org/apache/camel/component/corda/CordaProducerInvokeOnHeaderFactory.java b/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaProducerInvokeOnHeaderFactory.java
deleted file mode 100644
index b3bfe0b515e..00000000000
--- a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaProducerInvokeOnHeaderFactory.java
+++ /dev/null
@@ -1,100 +0,0 @@
-/* Generated by camel build tools - do NOT edit this file! */
-package org.apache.camel.component.corda;
-
-import org.apache.camel.AsyncCallback;
-import org.apache.camel.Exchange;
-import org.apache.camel.spi.InvokeOnHeaderStrategy;
-import org.apache.camel.component.corda.CordaProducer;
-
-/**
- * Generated by camel build tools - do NOT edit this file!
- */
-@SuppressWarnings("unchecked")
-public class CordaProducerInvokeOnHeaderFactory implements InvokeOnHeaderStrategy {
-
- @Override
- public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
- org.apache.camel.component.corda.CordaProducer target = (org.apache.camel.component.corda.CordaProducer) obj;
- switch (key) {
- case "accept_newnetwork_parameters":
- case "ACCEPT_NEWNETWORK_PARAMETERS": target.acceptNewNetworkParameters(exchange.getMessage()); return null;
- case "add_vault_transaction_note":
- case "ADD_VAULT_TRANSACTION_NOTE": target.addVaultTransactionNote(exchange.getMessage()); return null;
- case "attachment_exists":
- case "ATTACHMENT_EXISTS": target.attachmentExists(exchange.getMessage()); return null;
- case "clear_network_map_cache":
- case "CLEAR_NETWORK_MAP_CACHE": target.clearNetworkMapCache(exchange.getMessage()); return null;
- case "current_node_time":
- case "CURRENT_NODE_TIME": target.currentNodeTime(exchange.getMessage()); return null;
- case "get_protocol_version":
- case "GET_PROTOCOL_VERSION": target.getProtocolVersion(exchange.getMessage()); return null;
- case "get_vault_transaction_notes":
- case "GET_VAULT_TRANSACTION_NOTES": target.getVaultTransactionNotes(exchange.getMessage()); return null;
- case "is_flows_draining_mode_enabled":
- case "IS_FLOWS_DRAINING_MODE_ENABLED": target.isFlowsDrainingModeEnabled(exchange.getMessage()); return null;
- case "is_waiting_for_shutdown":
- case "IS_WAITING_FOR_SHUTDOWN": target.isWaitingForShutdown(exchange.getMessage()); return null;
- case "kill_flow":
- case "KILL_FLOW": target.killFlow(exchange.getMessage()); return null;
- case "network_map_snapshot":
- case "NETWORK_MAP_SNAPSHOT": target.networkMapSnapshot(exchange.getMessage()); return null;
- case "network_parameters_feed":
- case "NETWORK_PARAMETERS_FEED": target.networkParametersFeed(exchange.getMessage()); return null;
- case "node_info":
- case "NODE_INFO": target.nodeInfo(exchange.getMessage()); return null;
- case "node_info_from_party":
- case "NODE_INFO_FROM_PARTY": target.nodeInfoFromParty(exchange.getMessage()); return null;
- case "notary_identities":
- case "NOTARY_IDENTITIES": target.notaryIdentities(exchange.getMessage()); return null;
- case "notary_party_from_x500_name":
- case "NOTARY_PARTY_FROM_X500_NAME": target.notaryPartyFromX500Name(exchange.getMessage()); return null;
- case "open_attachment":
- case "OPEN_ATTACHMENT": target.openAttachment(exchange.getMessage()); return null;
- case "parties_from_key":
- case "PARTIES_FROM_KEY": target.partyFromKey(exchange.getMessage()); return null;
- case "parties_from_name":
- case "PARTIES_FROM_NAME": target.partiesFromName(exchange.getMessage()); return null;
- case "query_attachments":
- case "QUERY_ATTACHMENTS": target.queryAttachments(exchange.getMessage()); return null;
- case "refresh_network_map_cache":
- case "REFRESH_NETWORK_MAP_CACHE": target.refreshNetworkMapCache(exchange.getMessage()); return null;
- case "registered_flows":
- case "REGISTERED_FLOWS": target.registeredFlows(exchange.getMessage()); return null;
- case "set_flows_draining_mode_enabled":
- case "SET_FLOWS_DRAINING_MODE_ENABLED": target.setFlowsDrainingModeEnabled(exchange.getMessage()); return null;
- case "shutdown":
- case "SHUTDOWN": target.shutdown(exchange.getMessage()); return null;
- case "start_flow_dynamic":
- case "START_FLOW_DYNAMIC": target.startFlowDynamic(exchange.getMessage()); return null;
- case "state_machine_recorded_transaction_mapping_snapshot":
- case "STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_SNAPSHOT": target.stateMachineRecordedTransactionMappingSnapshot(exchange.getMessage()); return null;
- case "state_machine_snapshot":
- case "STATE_MACHINE_SNAPSHOT": target.stateMachinesSnapshot(exchange.getMessage()); return null;
- case "terminate":
- case "TERMINATE": target.terminate(exchange.getMessage()); return null;
- case "upload_attachment":
- case "UPLOAD_ATTACHMENT": target.uploadAttachment(exchange.getMessage()); return null;
- case "upload_attachment_with_meta_data":
- case "UPLOAD_ATTACHMENT_WITH_META_DATA": target.uploadAttachmentWithMetadata(exchange.getMessage()); return null;
- case "vault_query":
- case "VAULT_QUERY": target.vaultQuery(exchange.getMessage()); return null;
- case "vault_query_by":
- case "VAULT_QUERY_BY": target.vaultQueryBy(exchange.getMessage()); return null;
- case "vault_query_by_criteria":
- case "VAULT_QUERY_BY_CRITERIA": target.vaultQueryByCriteria(exchange.getMessage()); return null;
- case "vault_query_by_with_paging_spec":
- case "VAULT_QUERY_BY_WITH_PAGING_SPEC": target.vaultQueryByWithPagingSpec(exchange.getMessage()); return null;
- case "vault_query_by_with_sorting":
- case "VAULT_QUERY_BY_WITH_SORTING": target.vaultQueryByWithSorting(exchange.getMessage()); return null;
- case "wait_until_network_ready":
- case "WAIT_UNTIL_NETWORK_READY": target.waitUntilNetworkReady(exchange.getMessage()); return null;
- case "well_known_party_from_anonymous":
- case "WELL_KNOWN_PARTY_FROM_ANONYMOUS": target.wellKnownPartyFromAnonymous(exchange.getMessage()); return null;
- case "well_known_party_from_x500_name":
- case "WELL_KNOWN_PARTY_FROM_X500_NAME": target.wellKnownPartyFromX500Name(exchange.getMessage()); return null;
- default: return null;
- }
- }
-
-}
-
diff --git a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/component.properties b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/component.properties
deleted file mode 100644
index c09dedbd159..00000000000
--- a/components/camel-corda/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=corda
-groupId=org.apache.camel
-artifactId=camel-corda
-version=4.0.0-SNAPSHOT
-projectName=Camel :: Corda
-projectDescription=Camel Corda which is based on corda-rpc support
diff --git a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/component/corda b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/component/corda
deleted file mode 100644
index 55df0ab634e..00000000000
--- a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/component/corda
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.corda.CordaComponent
diff --git a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/configurer/corda-component b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/configurer/corda-component
deleted file mode 100644
index d70477aa74f..00000000000
--- a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/configurer/corda-component
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.corda.CordaComponentConfigurer
diff --git a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/configurer/corda-endpoint b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/configurer/corda-endpoint
deleted file mode 100644
index 85ecc671696..00000000000
--- a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/configurer/corda-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.corda.CordaEndpointConfigurer
diff --git a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.corda.CordaProducer b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.corda.CordaProducer
deleted file mode 100644
index 02842138a0c..00000000000
--- a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.corda.CordaProducer
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.corda.CordaProducerInvokeOnHeaderFactory
diff --git a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/urifactory/corda-endpoint b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/urifactory/corda-endpoint
deleted file mode 100644
index 4e060a84a40..00000000000
--- a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/urifactory/corda-endpoint
+++ /dev/null
@@ -1,2 +0,0 @@
-# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.corda.CordaEndpointUriFactory
diff --git a/components/camel-corda/src/generated/resources/org/apache/camel/component/corda/corda.json b/components/camel-corda/src/generated/resources/org/apache/camel/component/corda/corda.json
deleted file mode 100644
index 4842424a6dd..00000000000
--- a/components/camel-corda/src/generated/resources/org/apache/camel/component/corda/corda.json
+++ /dev/null
@@ -1,68 +0,0 @@
-{
- "component": {
- "kind": "component",
- "name": "corda",
- "title": "Corda",
- "description": "Perform operations against Corda blockchain platform using corda-rpc library.",
- "deprecated": false,
- "firstVersion": "2.23.0",
- "label": "blockchain,rpc",
- "javaType": "org.apache.camel.component.corda.CordaComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-corda",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "corda",
- "extendsScheme": "",
- "syntax": "corda:node",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
- "componentProperties": {
- "configuration": { "index": 0, "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.corda.CordaConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "To use a shared configuration." },
- "bridgeErrorHandler": { "index": 1, "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 proce [...]
- "pageSpecification": { "index": 2, "kind": "property", "displayName": "Page Specification", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.PageSpecification", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200", "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "PageSpecification allows specificati [...]
- "processSnapshot": { "index": 3, "kind": "property", "displayName": "Process Snapshot", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Whether to process snapshots or not" },
- "sort": { "index": 4, "kind": "property", "displayName": "Sort", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.Sort", "enum": [ "ASC", "DESC" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Sort allows specification of a set of entity attribute names and their a [...]
- "contractStateClass": { "index": 5, "kind": "property", "displayName": "Contract State Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.contracts.ContractState>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "A contract state (or just state) [...]
- "flowLogicArguments": { "index": 6, "kind": "property", "displayName": "Flow Logic Arguments", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "array", "javaType": "java.lang.Object[]", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the given arguments, returning an Observable [...]
- "flowLogicClass": { "index": 7, "kind": "property", "displayName": "Flow Logic Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.flows.FlowLogic<java.lang.Object>>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the g [...]
- "queryCriteria": { "index": 8, "kind": "property", "displayName": "Query Criteria", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.QueryCriteria", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "QueryCriteria assumes underlying schema tables are [...]
- "lazyStartProducer": { "index": 9, "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 [...]
- "operation": { "index": 10, "kind": "property", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Operation to use" },
- "autowiredEnabled": { "index": 11, "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 [...]
- "password": { "index": 12, "kind": "property", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Password for login" },
- "username": { "index": 13, "kind": "property", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Username for login" }
- },
- "headers": {
- "OPERATION": { "index": 0, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform", "constantName": "org.apache.camel.component.corda.CordaConstants#OPERATION" },
- "ATTACHMENT_QUERY_CRITERIA": { "index": 1, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.node.services.vault.AttachmentQueryCriteria", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The attachment query criteria", "constantName": "org.apache.camel.component.corda.CordaConstants#ATTACHMENT_QUERY_CRITERIA" },
- "SORT": { "index": 2, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The sort", "constantName": "org.apache.camel.component.corda.CordaConstants#SORT" },
- "EXACT_MATCH": { "index": 3, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If true, a case sensitive match is done against each component of each X.500 name.", "constantName": "org.apache.camel.component.corda.CordaConstants#EXACT_MATCH" },
- "ARGUMENTS": { "index": 4, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Object[]", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The arguments.", "constantName": "org.apache.camel.component.corda.CordaConstants#ARGUMENTS" },
- "DRAINING_MODE": { "index": 5, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Boolean", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The value of the node's flows draining mode.", "constantName": "org.apache.camel.component.corda.CordaConstants#DRAINING_MODE" },
- "SECURE_HASH": { "index": 6, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.crypto.SecureHash", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Container for a cryptographically secure hash value.", "constantName": "org.apache.camel.component.corda.CordaConstants#SECURE_HASH" },
- "QUERY_CRITERIA": { "index": 7, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.node.services.vault.QueryCriteria", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The query criteria.", "constantName": "org.apache.camel.component.corda.CordaConstants#QUERY_CRITERIA" },
- "PAGE_SPECIFICATION": { "index": 8, "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "net.corda.core.node.services.vault.PageSpecification", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The PageSpecification allows specification of a page number and page size", "constantName": "org.apache.camel.component.corda.CordaConstants#PAGE_SPECIFICATION" }
- },
- "properties": {
- "node": { "index": 0, "kind": "path", "displayName": "Node", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "The url for the corda node" },
- "pageSpecification": { "index": 1, "kind": "parameter", "displayName": "Page Specification", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.PageSpecification", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200", "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "PageSpecification allows specificat [...]
- "processSnapshot": { "index": 2, "kind": "parameter", "displayName": "Process Snapshot", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Whether to process snapshots or not" },
- "sort": { "index": 3, "kind": "parameter", "displayName": "Sort", "group": "consumer", "label": "consumer", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.Sort", "enum": [ "ASC", "DESC" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Sort allows specification of a set of entity attribute names and their [...]
- "bridgeErrorHandler": { "index": 4, "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 lik [...]
- "contractStateClass": { "index": 5, "kind": "parameter", "displayName": "Contract State Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.contracts.ContractState>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "A contract state (or just state) [...]
- "exceptionHandler": { "index": 6, "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 def [...]
- "exchangePattern": { "index": 7, "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
- "flowLogicArguments": { "index": 8, "kind": "parameter", "displayName": "Flow Logic Arguments", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "array", "javaType": "java.lang.Object[]", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the given arguments, returning an Observable [...]
- "flowLogicClass": { "index": 9, "kind": "parameter", "displayName": "Flow Logic Class", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "string", "javaType": "java.lang.Class<net.corda.core.flows.FlowLogic<java.lang.Object>>", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Start the given flow with the [...]
- "queryCriteria": { "index": 10, "kind": "parameter", "displayName": "Query Criteria", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "net.corda.core.node.services.vault.QueryCriteria", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "QueryCriteria assumes underlying schema tables ar [...]
- "operation": { "index": 11, "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Operation to use" },
- "lazyStartProducer": { "index": 12, "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 produ [...]
- "password": { "index": 13, "kind": "parameter", "displayName": "Password", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Password for login" },
- "username": { "index": 14, "kind": "parameter", "displayName": "Username", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.corda.CordaConfiguration", "configurationField": "configuration", "description": "Username for login" }
- }
-}
diff --git a/components/camel-corda/src/main/docs/corda-component.adoc b/components/camel-corda/src/main/docs/corda-component.adoc
deleted file mode 100644
index 74af31db241..00000000000
--- a/components/camel-corda/src/main/docs/corda-component.adoc
+++ /dev/null
@@ -1,77 +0,0 @@
-= Corda Component
-:doctitle: Corda
-:shortname: corda
-:artifactid: camel-corda
-:description: Perform operations against Corda blockchain platform using corda-rpc library.
-:since: 2.23
-:supportlevel: Stable
-:tabs-sync-option:
-:component-header: Both producer and consumer are supported
-//Manually maintained attributes
-:camel-spring-boot-name: corda
-
-
-*{component-header}*
-
-
-*Since Camel {since}*
-
-Camel connector for R3's https://www.corda.net/[Corda] blockchain platform using corda-rpc library.
-This component uses the Corda RPC client.
-
-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-corda</artifactId>
- <version>x.x.x</version>
- <!-- use the same version as your Camel core version -->
-</dependency>
-----
-
-== URI Format
-
-----
-corda://<host:port>[?options]
-----
-
-// 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
-
-== Samples
-
-Subscribe for new vault state changes:
-
-[source,java]
-----
-from("corda://localhost:10006?username=user1&password=test&operation=VAULT_TRACK&contractStateClass=#contractStateClass")
- .to("jms:queue:vault");
-----
-
-Read the node information:
-
-[source,java]
-----
-from("direct:start")
- .to("corda://localhost:10006?username=user1&password=test&operation=NODE_INFO");
-----
-
-
-include::spring-boot:partial$starter.adoc[]
diff --git a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaComponent.java b/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaComponent.java
deleted file mode 100644
index 69c84b783f7..00000000000
--- a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaComponent.java
+++ /dev/null
@@ -1,55 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.corda;
-
-import java.util.Map;
-
-import org.apache.camel.Endpoint;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.annotations.Component;
-import org.apache.camel.support.DefaultComponent;
-
-@Component("corda")
-public class CordaComponent extends DefaultComponent {
-
- @Metadata
- private CordaConfiguration configuration;
-
- public CordaConfiguration getConfiguration() {
- return configuration;
- }
-
- /**
- * To use a shared configuration.
- */
- public void setConfiguration(CordaConfiguration configuration) {
- this.configuration = configuration;
- }
-
- @Override
- protected Endpoint createEndpoint(String uri, final String remaining, final Map<String, Object> parameters)
- throws Exception {
- CordaConfiguration conf = configuration != null ? configuration.copy() : new CordaConfiguration();
- conf.setNode(remaining);
-
- CordaEndpoint endpoint = new CordaEndpoint(uri, this, conf);
- setProperties(endpoint, parameters);
- conf.configure();
- return endpoint;
- }
-
-}
diff --git a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConfiguration.java b/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConfiguration.java
deleted file mode 100644
index 256be618cf9..00000000000
--- a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConfiguration.java
+++ /dev/null
@@ -1,204 +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.corda;
-
-import java.net.URI;
-import java.net.URISyntaxException;
-
-import net.corda.core.contracts.ContractState;
-import net.corda.core.flows.FlowLogic;
-import net.corda.core.node.services.vault.PageSpecification;
-import net.corda.core.node.services.vault.QueryCriteria;
-import net.corda.core.node.services.vault.Sort;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.UriParam;
-import org.apache.camel.spi.UriParams;
-import org.apache.camel.spi.UriPath;
-
-@UriParams
-public class CordaConfiguration implements Cloneable {
-
- private transient String host;
- private transient int port;
-
- @UriPath
- @Metadata(required = true, description = "The url for the corda node")
- private String node;
- @UriParam(label = "producer", description = "Operation to use")
- private String operation;
- @UriParam(label = "security", secret = true, description = "Username for login")
- private String username;
- @UriParam(label = "security", secret = true, description = "Password for login")
- private String password;
- @UriParam(label = "consumer", defaultValue = "true", description = "Whether to process snapshots or not")
- private boolean processSnapshot = true;
-
- @UriParam(label = "consumer,advanced",
- description = "Start the given flow with the given arguments, returning an Observable with a single observation of the"
- + " result of running the flow. The flowLogicClass must be annotated with net.corda.core.flows.StartableByRPC.")
- private Class<FlowLogic<?>> flowLogicClass;
- @UriParam(label = "consumer,advanced",
- description = "Start the given flow with the given arguments, returning an Observable with a single observation of the"
- + " result of running the flow. The flowLogicClass must be annotated with net.corda.core.flows.StartableByRPC.")
- private Object[] flowLogicArguments;
- @UriParam(label = "consumer,advanced",
- description = "A contract state (or just state) contains opaque data used by a contract program. It can be thought of as a disk"
- + " file that the program can use to persist data across transactions. States are immutable: once created they are never"
- + " updated, instead, any changes must generate a new successor state. States can be updated (consumed) only once: the"
- + " notary is responsible for ensuring there is no \"double spending\" by only signing a transaction if the input states are all free.")
- private Class<ContractState> contractStateClass;
- @UriParam(label = "consumer,advanced",
- description = "QueryCriteria assumes underlying schema tables are correctly indexed for performance.")
- private QueryCriteria queryCriteria;
- @UriParam(label = "consumer", defaultValue = "200",
- description = "PageSpecification allows specification of a page number (starting from 1) and page size"
- + " (defaulting to 200 with a maximum page size of (Integer.MAX_INT)"
- + " Note: we default the page number to 200 to enable queries without requiring a page specification"
- + " but enabling detection of large results sets that fall out of the 200 requirement."
- + " Max page size should be used with extreme caution as results may exceed your JVM memory footprint.")
- private PageSpecification pageSpecification;
- @UriParam(label = "consumer", enums = "ASC,DESC",
- description = "Sort allows specification of a set of entity attribute names and their associated directionality"
- + " and null handling, to be applied upon processing a query specification.")
- private Sort sort;
-
- public void configure() {
- try {
- URI nodeURI = new URI(node);
- this.host = nodeURI.getHost();
- this.port = nodeURI.getPort();
-
- if (nodeURI.getUserInfo() != null) {
- String[] creds = nodeURI.getUserInfo().split(":");
- if (getUsername() == null) {
- setUsername(creds[0]);
- }
- if (getPassword() == null) {
- setPassword(creds.length > 1 ? creds[1] : "");
- }
- }
- } catch (URISyntaxException e) {
- throw new IllegalArgumentException("Invalid URI: " + node, e);
- }
- }
-
- public String retrieveHost() {
- return host;
- }
-
- public int retrievePort() {
- return port;
- }
-
- public String getNode() {
- return node;
- }
-
- public void setNode(String node) {
- this.node = node;
- }
-
- public String getOperation() {
- return operation;
- }
-
- public void setOperation(String operation) {
- this.operation = operation;
- }
-
- public String getUsername() {
- return username;
- }
-
- public void setUsername(String username) {
- this.username = username;
- }
-
- public String getPassword() {
- return password;
- }
-
- public void setPassword(String password) {
- this.password = password;
- }
-
- public boolean isProcessSnapshot() {
- return processSnapshot;
- }
-
- public void setProcessSnapshot(boolean processSnapshot) {
- this.processSnapshot = processSnapshot;
- }
-
- public Class<FlowLogic<?>> getFlowLogicClass() {
- return flowLogicClass;
- }
-
- public void setFlowLogicClass(Class<FlowLogic<?>> flowLogicClass) {
- this.flowLogicClass = flowLogicClass;
- }
-
- public Object[] getFlowLogicArguments() {
- return flowLogicArguments;
- }
-
- public void setFlowLogicArguments(Object[] flowLogicArguments) {
- this.flowLogicArguments = flowLogicArguments;
- }
-
- public Class<ContractState> getContractStateClass() {
- return contractStateClass;
- }
-
- public void setContractStateClass(Class<ContractState> contractStateClass) {
- this.contractStateClass = contractStateClass;
- }
-
- public QueryCriteria getQueryCriteria() {
- return queryCriteria;
- }
-
- public void setQueryCriteria(QueryCriteria queryCriteria) {
- this.queryCriteria = queryCriteria;
- }
-
- public PageSpecification getPageSpecification() {
- return pageSpecification;
- }
-
- public void setPageSpecification(PageSpecification pageSpecification) {
- this.pageSpecification = pageSpecification;
- }
-
- public Sort getSort() {
- return sort;
- }
-
- public void setSort(Sort sort) {
- this.sort = sort;
- }
-
- public CordaConfiguration copy() {
- try {
- return (CordaConfiguration) super.clone();
- } catch (CloneNotSupportedException e) {
- throw new RuntimeCamelException(e);
- }
- }
-
-}
diff --git a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConstants.java b/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConstants.java
deleted file mode 100644
index fd8a22a1bd2..00000000000
--- a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConstants.java
+++ /dev/null
@@ -1,97 +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.corda;
-
-import org.apache.camel.spi.Metadata;
-
-public interface CordaConstants {
- @Metadata(label = "producer", description = "The operation to perform", javaType = "String")
- String OPERATION = "OPERATION";
- String NODE_INFO = "NODE_INFO";
- String CURRENT_NODE_TIME = "CURRENT_NODE_TIME";
- String GET_PROTOCOL_VERSION = "GET_PROTOCOL_VERSION";
- String NETWORK_MAP_SNAPSHOT = "NETWORK_MAP_SNAPSHOT";
- String REGISTERED_FLOWS = "REGISTERED_FLOWS";
- String CLEAR_NETWORK_MAP_CACHE = "CLEAR_NETWORK_MAP_CACHE";
- String IS_FLOWS_DRAINING_MODE_ENABLED = "IS_FLOWS_DRAINING_MODE_ENABLED";
- String ADD_VAULT_TRANSACTION_NOTE = "ADD_VAULT_TRANSACTION_NOTE";
- String NOTARY_IDENTITIES = "NOTARY_IDENTITIES";
- String SET_FLOWS_DRAINING_MODE_ENABLED = "SET_FLOWS_DRAINING_MODE_ENABLED";
- String GET_VAULT_TRANSACTION_NOTES = "GET_VAULT_TRANSACTION_NOTES";
- String UPLOAD_ATTACHMENT = "UPLOAD_ATTACHMENT";
- String ATTACHMENT_EXISTS = "ATTACHMENT_EXISTS";
- String OPEN_ATTACHMENT = "OPEN_ATTACHMENT";
- String QUERY_ATTACHMENTS = "QUERY_ATTACHMENTS";
- String NODE_INFO_FROM_PARTY = "NODE_INFO_FROM_PARTY";
- String NOTARY_PARTY_FROM_X500_NAME = "NOTARY_PARTY_FROM_X500_NAME";
- String PARTIES_FROM_NAME = "PARTIES_FROM_NAME";
- String PARTIES_FROM_KEY = "PARTIES_FROM_KEY";
- String START_FLOW_DYNAMIC = "START_FLOW_DYNAMIC";
- String STATE_MACHINE_SNAPSHOT = "STATE_MACHINE_SNAPSHOT";
- String STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_SNAPSHOT = "STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_SNAPSHOT";
- String WELL_KNOWN_PARTY_FROM_X500_NAME = "WELL_KNOWN_PARTY_FROM_X500_NAME";
- String WELL_KNOWN_PARTY_FROM_ANONYMOUS = "WELL_KNOWN_PARTY_FROM_ANONYMOUS";
- String VAULT_QUERY = "VAULT_QUERY";
- String VAULT_QUERY_BY = "VAULT_QUERY_BY";
- String VAULT_QUERY_BY_CRITERIA = "VAULT_QUERY_BY_CRITERIA";
- String VAULT_QUERY_BY_WITH_PAGING_SPEC = "VAULT_QUERY_BY_WITH_PAGING_SPEC";
- String VAULT_QUERY_BY_WITH_SORTING = "VAULT_QUERY_BY_WITH_SORTING";
-
- String VAULT_TRACK = "VAULT_TRACK";
- String VAULT_TRACK_BY = "VAULT_TRACK_BY";
- String VAULT_TRACK_BY_CRITERIA = "VAULT_TRACK_BY_CRITERIA";
- String VAULT_TRACK_BY_WITH_PAGING_SPEC = "VAULT_TRACK_BY_WITH_PAGING_SPEC";
- String VAULT_TRACK_BY_WITH_SORTING = "VAULT_TRACK_BY_WITH_SORTING";
- String STATE_MACHINE_FEED = "STATE_MACHINE_FEED";
- String NETWORK_MAP_FEED = "NETWORK_MAP_FEED";
- String STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED = "STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED";
- String START_TRACKED_FLOW_DYNAMIC = "START_TRACKED_FLOW_DYNAMIC";
-
- @Metadata(label = "producer", description = "The attachment query criteria",
- javaType = "net.corda.core.node.services.vault.AttachmentQueryCriteria")
- String ATTACHMENT_QUERY_CRITERIA = "ATTACHMENT_QUERY_CRITERIA";
- @Metadata(label = "producer", description = "The sort")
- String SORT = "SORT";
- @Metadata(label = "producer",
- description = "If true, a case sensitive match is done against each component of each X.500 name.",
- javaType = "Boolean")
- String EXACT_MATCH = "EXACT_MATCH";
- @Metadata(label = "producer", description = "The arguments.", javaType = "Object[]")
- String ARGUMENTS = "ARGUMENTS";
- @Metadata(label = "producer", description = "The value of the node's flows draining mode.", javaType = "Boolean")
- String DRAINING_MODE = "DRAINING_MODE";
- @Metadata(label = "producer", description = "Container for a cryptographically secure hash value.",
- javaType = "net.corda.core.crypto.SecureHash")
- String SECURE_HASH = "SECURE_HASH";
- @Metadata(label = "producer", description = "The query criteria.",
- javaType = "net.corda.core.node.services.vault.QueryCriteria")
- String QUERY_CRITERIA = "QUERY_CRITERIA";
- @Metadata(label = "producer", description = "The PageSpecification allows specification of a page number and page size",
- javaType = "net.corda.core.node.services.vault.PageSpecification")
- String PAGE_SPECIFICATION = "PAGE_SPECIFICATION";
-
- String TERMINATE = "TERMINATE";
- String ACCEPT_NEWNETWORK_PARAMETERS = "ACCEPT_NEWNETWORK_PARAMETERS";
- String IS_WAITING_FOR_SHUTDOWN = "IS_WAITING_FOR_SHUTDOWN";
- String KILL_FLOW = "KILL_FLOW";
- String NETWORK_PARAMETERS_FEED = "NETWORK_PARAMETERS_FEED";
- String REFRESH_NETWORK_MAP_CACHE = "REFRESH_NETWORK_MAP_CACHE";
- String SHUTDOWN = "SHUTDOWN";
- String UPLOAD_ATTACHMENT_WITH_META_DATA = "UPLOAD_ATTACHMENT_WITH_META_DATA";
- String WAIT_UNTIL_NETWORK_READY = "WAIT_UNTIL_NETWORK_READY";
-
-}
diff --git a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConsumer.java b/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConsumer.java
deleted file mode 100644
index 33f96c567a0..00000000000
--- a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaConsumer.java
+++ /dev/null
@@ -1,262 +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.corda;
-
-import java.util.List;
-
-import net.corda.core.contracts.ContractState;
-import net.corda.core.messaging.CordaRPCOps;
-import net.corda.core.messaging.DataFeed;
-import net.corda.core.messaging.FlowProgressHandle;
-import net.corda.core.messaging.StateMachineInfo;
-import net.corda.core.messaging.StateMachineTransactionMapping;
-import net.corda.core.messaging.StateMachineUpdate;
-import net.corda.core.node.NodeInfo;
-import net.corda.core.node.services.NetworkMapCache;
-import net.corda.core.node.services.Vault;
-import net.corda.core.node.services.vault.PageSpecification;
-import net.corda.core.node.services.vault.QueryCriteria;
-import net.corda.core.node.services.vault.Sort;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.support.DefaultConsumer;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import rx.Observable;
-import rx.Subscription;
-
-import static org.apache.camel.component.corda.CordaConstants.NETWORK_MAP_FEED;
-import static org.apache.camel.component.corda.CordaConstants.START_TRACKED_FLOW_DYNAMIC;
-import static org.apache.camel.component.corda.CordaConstants.STATE_MACHINE_FEED;
-import static org.apache.camel.component.corda.CordaConstants.STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY_CRITERIA;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY_WITH_PAGING_SPEC;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY_WITH_SORTING;
-
-/**
- * The corda consumer.
- */
-public class CordaConsumer extends DefaultConsumer {
- private static final Logger LOG = LoggerFactory.getLogger(CordaConsumer.class);
- private final CordaConfiguration configuration;
- private CordaRPCOps cordaRPCOps;
- private Subscription subscription;
-
- public CordaConsumer(CordaEndpoint endpoint, Processor processor, CordaConfiguration configuration,
- CordaRPCOps cordaRPCOps) {
- super(endpoint, processor);
- this.configuration = configuration;
- this.cordaRPCOps = cordaRPCOps;
- }
-
- @Override
- public CordaEndpoint getEndpoint() {
- return (CordaEndpoint) super.getEndpoint();
- }
-
- @Override
- protected void doStart() throws Exception {
- super.doStart();
- Exchange exchange = this.getEndpoint().createExchange();
- Class<ContractState> contractStateClass = configuration.getContractStateClass();
- QueryCriteria criteria = configuration.getQueryCriteria();
- PageSpecification pageSpec = configuration.getPageSpecification();
- Sort sorting = configuration.getSort();
-
- DataFeed<Vault.Page<ContractState>, Vault.Update<ContractState>> pageUpdateDataFeed;
- switch (configuration.getOperation()) {
-
- case VAULT_TRACK:
- LOG.debug("subscribing for operation: " + VAULT_TRACK);
- pageUpdateDataFeed = cordaRPCOps.vaultTrack(contractStateClass);
- processSnapshot(exchange, pageUpdateDataFeed.getSnapshot());
- subscription = pageUpdateDataFeed.getUpdates().subscribe(
- x -> processContractStateUpdate(x),
- t -> processError(t, CordaConstants.VAULT_TRACK),
- () -> processDone(CordaConstants.VAULT_TRACK));
- break;
-
- case VAULT_TRACK_BY:
- LOG.debug("subscribing for operation: " + VAULT_TRACK_BY);
- pageUpdateDataFeed = cordaRPCOps.vaultTrackBy(criteria, pageSpec, sorting, contractStateClass);
- processSnapshot(exchange, pageUpdateDataFeed.getSnapshot());
- subscription = pageUpdateDataFeed.getUpdates().subscribe(
- x -> processContractStateUpdate(x),
- t -> processError(t, CordaConstants.VAULT_TRACK_BY),
- () -> processDone(CordaConstants.VAULT_TRACK_BY));
- break;
-
- case VAULT_TRACK_BY_CRITERIA:
- LOG.debug("subscribing for operation: " + VAULT_TRACK_BY_CRITERIA);
- pageUpdateDataFeed = cordaRPCOps.vaultTrackByCriteria(contractStateClass, criteria);
- processSnapshot(exchange, pageUpdateDataFeed.getSnapshot());
- subscription = pageUpdateDataFeed.getUpdates().subscribe(
- x -> processContractStateUpdate(x),
- t -> processError(t, CordaConstants.VAULT_TRACK_BY_CRITERIA),
- () -> processDone(CordaConstants.VAULT_TRACK_BY_CRITERIA));
- break;
-
- case VAULT_TRACK_BY_WITH_PAGING_SPEC:
- LOG.debug("subscribing for operation: " + VAULT_TRACK_BY_WITH_PAGING_SPEC);
- pageUpdateDataFeed = cordaRPCOps.vaultTrackByWithPagingSpec(contractStateClass, criteria, pageSpec);
- processSnapshot(exchange, pageUpdateDataFeed.getSnapshot());
- subscription = pageUpdateDataFeed.getUpdates().subscribe(
- x -> processContractStateUpdate(x),
- t -> processError(t, CordaConstants.VAULT_TRACK_BY_WITH_PAGING_SPEC),
- () -> processDone(CordaConstants.VAULT_TRACK_BY_WITH_PAGING_SPEC));
- break;
-
- case VAULT_TRACK_BY_WITH_SORTING:
- LOG.debug("subscribing for operation: " + VAULT_TRACK_BY_WITH_SORTING);
- pageUpdateDataFeed = cordaRPCOps.vaultTrackByWithSorting(contractStateClass, criteria, sorting);
- processSnapshot(exchange, pageUpdateDataFeed.getSnapshot());
- subscription = pageUpdateDataFeed.getUpdates().subscribe(
- x -> processContractStateUpdate(x),
- t -> processError(t, CordaConstants.VAULT_TRACK_BY_WITH_SORTING),
- () -> processDone(CordaConstants.VAULT_TRACK_BY_WITH_SORTING));
- break;
-
- case STATE_MACHINE_FEED:
- LOG.debug("subscribing for operation: " + STATE_MACHINE_FEED);
- DataFeed<List<StateMachineInfo>, StateMachineUpdate> stateFeed = cordaRPCOps.stateMachinesFeed();
- processSnapshot(exchange, stateFeed.getSnapshot());
- subscription = stateFeed.getUpdates().subscribe(
- x -> processStateMachineUpdate(x),
- t -> processError(t, CordaConstants.STATE_MACHINE_FEED),
- () -> processDone(CordaConstants.STATE_MACHINE_FEED));
- break;
-
- case NETWORK_MAP_FEED:
- LOG.debug("subscribing for operation: " + NETWORK_MAP_FEED);
-
- DataFeed<List<NodeInfo>, NetworkMapCache.MapChange> networkMapFeed = cordaRPCOps.networkMapFeed();
- processSnapshot(exchange, networkMapFeed.getSnapshot());
- subscription = networkMapFeed.getUpdates().subscribe(
- x -> proceedNetworkMapFeed(x),
- t -> processError(t, CordaConstants.NETWORK_MAP_FEED),
- () -> processDone(CordaConstants.NETWORK_MAP_FEED));
- break;
-
- case STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED:
- LOG.debug("subscribing for operation: " + STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED);
-
- DataFeed<List<StateMachineTransactionMapping>, StateMachineTransactionMapping> transactionFeed
- = cordaRPCOps.stateMachineRecordedTransactionMappingFeed();
- processSnapshot(exchange, transactionFeed.getSnapshot());
- subscription = transactionFeed.getUpdates().subscribe(
- x -> processTransactionMappingFeed(x),
- t -> processError(t, CordaConstants.STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED),
- () -> processDone(CordaConstants.STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED));
- break;
-
- case START_TRACKED_FLOW_DYNAMIC:
- LOG.debug("subscribing for operation: " + START_TRACKED_FLOW_DYNAMIC);
-
- FlowProgressHandle<Object> objectFlowProgressHandle = cordaRPCOps
- .startTrackedFlowDynamic(configuration.getFlowLogicClass(), configuration.getFlowLogicArguments());
- Object result = objectFlowProgressHandle.getReturnValue().get();
- Observable<String> progress = objectFlowProgressHandle.getProgress();
- processSnapshot(exchange, result);
- subscription = progress.subscribe(
- x -> processFlowProcess(x),
- t -> processError(t, CordaConstants.START_TRACKED_FLOW_DYNAMIC),
- () -> processDone(CordaConstants.START_TRACKED_FLOW_DYNAMIC));
- break;
-
- default:
- throw new IllegalArgumentException("Unsupported operation " + configuration.getOperation());
- }
-
- LOG.info("Subscribed: {}", this.configuration);
- }
-
- private void processSnapshot(Exchange exchange, Object page) {
- if (configuration.isProcessSnapshot()) {
- try {
- exchange.getIn().setBody(page);
- getProcessor().process(exchange);
- } catch (Exception e) {
- LOG.error("Error processing snapshot", e);
- }
- }
- }
-
- private void processFlowProcess(String x) {
- LOG.debug("processFlowProcess {}", x);
- Exchange exchange = createExchange(true);
- exchange.getIn().setBody(x);
- processEvent(exchange);
- }
-
- private void processTransactionMappingFeed(StateMachineTransactionMapping x) {
- LOG.debug("processTransactionMappingFeed {}", x);
- Exchange exchange = createExchange(true);
- exchange.getIn().setBody(x);
- processEvent(exchange);
- }
-
- private void proceedNetworkMapFeed(NetworkMapCache.MapChange x) {
- LOG.debug("proceedNetworkMapFeed {}", x);
- Exchange exchange = createExchange(true);
- exchange.getIn().setBody(x);
- processEvent(exchange);
- }
-
- private void processStateMachineUpdate(StateMachineUpdate x) {
- LOG.debug("processStateMachineUpdate {}", x);
- Exchange exchange = createExchange(true);
- exchange.getIn().setBody(x);
- processEvent(exchange);
- }
-
- private void processContractStateUpdate(Vault.Update<ContractState> x) {
- LOG.debug("processContractStateUpdate {}", x);
- Exchange exchange = createExchange(true);
- exchange.getIn().setBody(x);
- processEvent(exchange);
- }
-
- private void processError(Throwable throwable, String operation) {
- LOG.debug("processError for operation: {} {}", operation, throwable);
- Exchange exchange = createExchange(true);
- exchange.setException(throwable);
- processEvent(exchange);
- }
-
- public void processEvent(Exchange exchange) {
- LOG.debug("processEvent {}", exchange);
- try {
- getProcessor().process(exchange);
- } catch (Exception e) {
- getExceptionHandler().handleException("Error processing event", e);
- }
- }
-
- private void processDone(String operation) {
- LOG.debug("processDone for operation: {}", operation);
- }
-
- @Override
- protected void doStop() throws Exception {
- if (subscription != null) {
- subscription.unsubscribe();
- }
- super.doStop();
- }
-}
diff --git a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaEndpoint.java b/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaEndpoint.java
deleted file mode 100644
index dcb4b0c2017..00000000000
--- a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaEndpoint.java
+++ /dev/null
@@ -1,86 +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.corda;
-
-import net.corda.client.rpc.CordaRPCClient;
-import net.corda.client.rpc.CordaRPCConnection;
-import net.corda.core.messaging.CordaRPCOps;
-import net.corda.core.utilities.NetworkHostAndPort;
-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;
-
-/**
- * Perform operations against Corda blockchain platform using corda-rpc library.
- */
-@UriEndpoint(firstVersion = "2.23.0", scheme = "corda", title = "Corda", syntax = "corda:node",
- category = { Category.BLOCKCHAIN, Category.RPC }, headersClass = CordaConstants.class)
-public class CordaEndpoint extends DefaultEndpoint {
-
- @UriParam
- private CordaConfiguration configuration;
-
- private CordaRPCConnection rpcConnection;
- private CordaRPCOps proxy;
-
- public CordaEndpoint(String uri, CordaComponent component, CordaConfiguration configuration) {
- super(uri, component);
- this.configuration = configuration;
- }
-
- @Override
- public Producer createProducer() throws Exception {
- return new CordaProducer(this, configuration, proxy);
- }
-
- @Override
- public Consumer createConsumer(Processor processor) throws Exception {
- CordaConsumer consumer = new CordaConsumer(this, processor, configuration, proxy);
- configureConsumer(consumer);
- return consumer;
- }
-
- public CordaConfiguration getConfiguration() {
- return configuration;
- }
-
- public void setConfiguration(CordaConfiguration configuration) {
- this.configuration = configuration;
- }
-
- @Override
- protected void doStart() throws Exception {
- NetworkHostAndPort rpcAddress = new NetworkHostAndPort(configuration.retrieveHost(), configuration.retrievePort());
- CordaRPCClient rpcClient = new CordaRPCClient(rpcAddress);
- rpcConnection = rpcClient.start(this.configuration.getUsername(), this.configuration.getPassword());
- proxy = rpcConnection.getProxy();
- super.doStart();
- }
-
- @Override
- protected void doStop() throws Exception {
- if (rpcConnection != null) {
- rpcConnection.notifyServerAndClose();
- }
- super.doStop();
- }
-
-}
diff --git a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaProducer.java b/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaProducer.java
deleted file mode 100644
index 501983de6d8..00000000000
--- a/components/camel-corda/src/main/java/org/apache/camel/component/corda/CordaProducer.java
+++ /dev/null
@@ -1,295 +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.corda;
-
-import java.io.InputStream;
-import java.nio.file.FileAlreadyExistsException;
-import java.security.PublicKey;
-import java.util.concurrent.ExecutionException;
-
-import net.corda.core.contracts.ContractState;
-import net.corda.core.crypto.SecureHash;
-import net.corda.core.flows.FlowLogic;
-import net.corda.core.flows.StateMachineRunId;
-import net.corda.core.identity.AbstractParty;
-import net.corda.core.identity.CordaX500Name;
-import net.corda.core.messaging.CordaRPCOps;
-import net.corda.core.node.services.vault.AttachmentQueryCriteria;
-import net.corda.core.node.services.vault.AttachmentSort;
-import net.corda.core.node.services.vault.PageSpecification;
-import net.corda.core.node.services.vault.QueryCriteria;
-import net.corda.core.node.services.vault.Sort;
-import org.apache.camel.Message;
-import org.apache.camel.spi.InvokeOnHeader;
-import org.apache.camel.support.HeaderSelectorProducer;
-
-import static org.apache.camel.component.corda.CordaConstants.ARGUMENTS;
-import static org.apache.camel.component.corda.CordaConstants.ATTACHMENT_QUERY_CRITERIA;
-import static org.apache.camel.component.corda.CordaConstants.DRAINING_MODE;
-import static org.apache.camel.component.corda.CordaConstants.EXACT_MATCH;
-import static org.apache.camel.component.corda.CordaConstants.PAGE_SPECIFICATION;
-import static org.apache.camel.component.corda.CordaConstants.QUERY_CRITERIA;
-import static org.apache.camel.component.corda.CordaConstants.SECURE_HASH;
-import static org.apache.camel.component.corda.CordaConstants.SORT;
-
-/**
- * The corda producer.
- */
-
-public class CordaProducer extends HeaderSelectorProducer {
- //private CordaConfiguration configuration;
- private CordaRPCOps cordaRPCOps;
-
- public CordaProducer(CordaEndpoint endpoint, final CordaConfiguration configuration, CordaRPCOps cordaRPCOps) {
- super(endpoint, CordaConstants.OPERATION, () -> configuration.getOperation());
- //this.configuration = configuration;
- this.cordaRPCOps = cordaRPCOps;
- }
-
- @Override
- public CordaEndpoint getEndpoint() {
- return (CordaEndpoint) super.getEndpoint();
- }
-
- @InvokeOnHeader(CordaConstants.CURRENT_NODE_TIME)
- void currentNodeTime(Message message) {
- message.setBody(cordaRPCOps.currentNodeTime());
- }
-
- @InvokeOnHeader(CordaConstants.GET_PROTOCOL_VERSION)
- void getProtocolVersion(Message message) {
- message.setBody(cordaRPCOps.getProtocolVersion());
- }
-
- @InvokeOnHeader(CordaConstants.NETWORK_MAP_SNAPSHOT)
- void networkMapSnapshot(Message message) {
- message.setBody(cordaRPCOps.networkMapSnapshot());
- }
-
- @InvokeOnHeader(CordaConstants.STATE_MACHINE_SNAPSHOT)
- void stateMachinesSnapshot(Message message) {
- message.setBody(cordaRPCOps.stateMachinesSnapshot());
- }
-
- @InvokeOnHeader(CordaConstants.STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_SNAPSHOT)
- void stateMachineRecordedTransactionMappingSnapshot(Message message) {
- message.setBody(cordaRPCOps.stateMachineRecordedTransactionMappingSnapshot());
- }
-
- @InvokeOnHeader(CordaConstants.REGISTERED_FLOWS)
- void registeredFlows(Message message) {
- message.setBody(cordaRPCOps.registeredFlows());
- }
-
- @InvokeOnHeader(CordaConstants.CLEAR_NETWORK_MAP_CACHE)
- void clearNetworkMapCache(Message message) {
- cordaRPCOps.clearNetworkMapCache();
- }
-
- @InvokeOnHeader(CordaConstants.IS_FLOWS_DRAINING_MODE_ENABLED)
- void isFlowsDrainingModeEnabled(Message message) {
- message.setBody(cordaRPCOps.isFlowsDrainingModeEnabled());
- }
-
- @InvokeOnHeader(CordaConstants.SET_FLOWS_DRAINING_MODE_ENABLED)
- void setFlowsDrainingModeEnabled(Message message) {
- Boolean mode = message.getHeader(DRAINING_MODE, Boolean.class);
- cordaRPCOps.setFlowsDrainingModeEnabled(mode);
- }
-
- @InvokeOnHeader(CordaConstants.NOTARY_IDENTITIES)
- void notaryIdentities(Message message) {
- message.setBody(cordaRPCOps.notaryIdentities());
- }
-
- @InvokeOnHeader(CordaConstants.NODE_INFO)
- void nodeInfo(Message message) {
- message.setBody(cordaRPCOps.nodeInfo());
- }
-
- @InvokeOnHeader(CordaConstants.ADD_VAULT_TRANSACTION_NOTE)
- void addVaultTransactionNote(Message message) {
- SecureHash secureHash = message.getHeader(SECURE_HASH, SecureHash.class);
- String note = message.getBody(String.class);
- cordaRPCOps.addVaultTransactionNote(secureHash, note);
- }
-
- @InvokeOnHeader(CordaConstants.GET_VAULT_TRANSACTION_NOTES)
- void getVaultTransactionNotes(Message message) {
- SecureHash secureHash = message.getHeader(SECURE_HASH, SecureHash.class);
- message.setBody(cordaRPCOps.getVaultTransactionNotes(secureHash));
- }
-
- @InvokeOnHeader(CordaConstants.UPLOAD_ATTACHMENT)
- void uploadAttachment(Message message) throws FileAlreadyExistsException {
- InputStream inputStream = message.getBody(InputStream.class);
- SecureHash secureHash = cordaRPCOps.uploadAttachment(inputStream);
- message.setHeader(SECURE_HASH, secureHash);
- }
-
- @InvokeOnHeader(CordaConstants.ATTACHMENT_EXISTS)
- void attachmentExists(Message message) {
- SecureHash secureHash = message.getHeader(SECURE_HASH, SecureHash.class);
- message.setBody(cordaRPCOps.attachmentExists(secureHash));
- }
-
- @InvokeOnHeader(CordaConstants.OPEN_ATTACHMENT)
- void openAttachment(Message message) {
- SecureHash secureHash = message.getHeader(SECURE_HASH, SecureHash.class);
- message.setBody(cordaRPCOps.openAttachment(secureHash));
- }
-
- @InvokeOnHeader(CordaConstants.QUERY_ATTACHMENTS)
- void queryAttachments(Message message) {
- AttachmentQueryCriteria queryCriteria = message.getHeader(ATTACHMENT_QUERY_CRITERIA, AttachmentQueryCriteria.class);
- AttachmentSort attachmentSort = message.getHeader(SORT, AttachmentSort.class);
- message.setBody(cordaRPCOps.queryAttachments(queryCriteria, attachmentSort));
- }
-
- @InvokeOnHeader(CordaConstants.NODE_INFO_FROM_PARTY)
- void nodeInfoFromParty(Message message) {
- AbstractParty party = message.getBody(AbstractParty.class);
- message.setBody(cordaRPCOps.nodeInfoFromParty(party));
- }
-
- @InvokeOnHeader(CordaConstants.NOTARY_PARTY_FROM_X500_NAME)
- void notaryPartyFromX500Name(Message message) {
- CordaX500Name x500Name = message.getBody(CordaX500Name.class);
- message.setBody(cordaRPCOps.notaryPartyFromX500Name(x500Name));
- }
-
- @InvokeOnHeader(CordaConstants.PARTIES_FROM_NAME)
- void partiesFromName(Message message) {
- String query = message.getBody(String.class);
- Boolean exactMatch = message.getHeader(EXACT_MATCH, Boolean.class);
- message.setBody(cordaRPCOps.partiesFromName(query, exactMatch));
- }
-
- @InvokeOnHeader(CordaConstants.PARTIES_FROM_KEY)
- void partyFromKey(Message message) {
- PublicKey key = message.getBody(PublicKey.class);
- message.setBody(cordaRPCOps.partyFromKey(key));
- }
-
- @InvokeOnHeader(CordaConstants.WELL_KNOWN_PARTY_FROM_X500_NAME)
- void wellKnownPartyFromX500Name(Message message) {
- CordaX500Name x500Name = message.getBody(CordaX500Name.class);
- message.setBody(cordaRPCOps.wellKnownPartyFromX500Name(x500Name));
- }
-
- @InvokeOnHeader(CordaConstants.WELL_KNOWN_PARTY_FROM_ANONYMOUS)
- void wellKnownPartyFromAnonymous(Message message) {
- AbstractParty party = message.getBody(AbstractParty.class);
- message.setBody(cordaRPCOps.wellKnownPartyFromAnonymous(party));
- }
-
- @InvokeOnHeader(CordaConstants.START_FLOW_DYNAMIC)
- void startFlowDynamic(Message message) throws ExecutionException, InterruptedException {
- Object[] args = message.getHeader(ARGUMENTS, Object[].class);
- Class<FlowLogic<?>> aClass = message.getBody(Class.class);
- message.setBody(cordaRPCOps.startFlowDynamic(aClass, args).getReturnValue().get());
- }
-
- @InvokeOnHeader(CordaConstants.VAULT_QUERY)
- void vaultQuery(Message message) {
- Class<ContractState> contractStateClass = message.getBody(Class.class);
- message.setBody(cordaRPCOps.vaultQuery(contractStateClass));
- }
-
- @InvokeOnHeader(CordaConstants.VAULT_QUERY_BY)
- void vaultQueryBy(Message message) {
- Class<ContractState> contractStateClass = message.getBody(Class.class);
- QueryCriteria criteria = message.getHeader(QUERY_CRITERIA, QueryCriteria.class);
- PageSpecification pageSpec = message.getHeader(PAGE_SPECIFICATION, PageSpecification.class);
- Sort sorting = message.getHeader(SORT, Sort.class);
- message.setBody(cordaRPCOps.vaultQueryBy(criteria, pageSpec, sorting, contractStateClass));
- }
-
- @InvokeOnHeader(CordaConstants.VAULT_QUERY_BY_CRITERIA)
- void vaultQueryByCriteria(Message message) {
- Class<ContractState> contractStateClass = message.getBody(Class.class);
- QueryCriteria criteria = message.getHeader(QUERY_CRITERIA, QueryCriteria.class);
- message.setBody(cordaRPCOps.vaultQueryByCriteria(criteria, contractStateClass));
- }
-
- @InvokeOnHeader(CordaConstants.VAULT_QUERY_BY_WITH_PAGING_SPEC)
- void vaultQueryByWithPagingSpec(Message message) {
- Class<ContractState> contractStateClass = message.getBody(Class.class);
- QueryCriteria criteria = message.getHeader(QUERY_CRITERIA, QueryCriteria.class);
- PageSpecification pageSpec = message.getHeader(PAGE_SPECIFICATION, PageSpecification.class);
- message.setBody(cordaRPCOps.vaultQueryByWithPagingSpec(contractStateClass, criteria, pageSpec));
- }
-
- @InvokeOnHeader(CordaConstants.VAULT_QUERY_BY_WITH_SORTING)
- void vaultQueryByWithSorting(Message message) {
- Class<ContractState> contractStateClass = message.getBody(Class.class);
- QueryCriteria criteria = message.getHeader(QUERY_CRITERIA, QueryCriteria.class);
- Sort sorting = message.getHeader(SORT, Sort.class);
- message.setBody(cordaRPCOps.vaultQueryByWithSorting(contractStateClass, criteria, sorting));
- }
-
- @InvokeOnHeader(CordaConstants.TERMINATE)
- void terminate(Message message) {
- cordaRPCOps.terminate(true);
- }
-
- @InvokeOnHeader(CordaConstants.IS_WAITING_FOR_SHUTDOWN)
- void isWaitingForShutdown(Message message) {
- message.setBody(cordaRPCOps.isWaitingForShutdown());
- }
-
- @InvokeOnHeader(CordaConstants.REFRESH_NETWORK_MAP_CACHE)
- void refreshNetworkMapCache(Message message) {
- cordaRPCOps.refreshNetworkMapCache();
- }
-
- @InvokeOnHeader(CordaConstants.SHUTDOWN)
- void shutdown(Message message) {
- cordaRPCOps.shutdown();
- }
-
- @InvokeOnHeader(CordaConstants.WAIT_UNTIL_NETWORK_READY)
- void waitUntilNetworkReady(Message message) {
- message.setBody(cordaRPCOps.waitUntilNetworkReady());
- }
-
- @InvokeOnHeader(CordaConstants.ACCEPT_NEWNETWORK_PARAMETERS)
- void acceptNewNetworkParameters(Message message) {
- SecureHash secureHash = message.getHeader(SECURE_HASH, SecureHash.class);
- cordaRPCOps.acceptNewNetworkParameters(secureHash);
- }
-
- @InvokeOnHeader(CordaConstants.KILL_FLOW)
- void killFlow(Message message) {
- StateMachineRunId stateMachineRunId = message.getBody(StateMachineRunId.class);
- cordaRPCOps.killFlow(stateMachineRunId);
- }
-
- @InvokeOnHeader(CordaConstants.NETWORK_PARAMETERS_FEED)
- void networkParametersFeed(Message message) {
- message.setBody(cordaRPCOps.networkParametersFeed());
- }
-
- @InvokeOnHeader(CordaConstants.UPLOAD_ATTACHMENT_WITH_META_DATA)
- void uploadAttachmentWithMetadata(Message message) throws FileAlreadyExistsException {
- InputStream inputStream = message.getBody(InputStream.class);
- String uploader = message.getBody(String.class);
- String filename = message.getBody(String.class);
- SecureHash secureHash = cordaRPCOps.uploadAttachmentWithMetadata(inputStream, uploader, filename);
- message.setHeader(SECURE_HASH, secureHash);
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CamelFlow.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CamelFlow.java
deleted file mode 100644
index ddbcd6e491b..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CamelFlow.java
+++ /dev/null
@@ -1,32 +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.corda;
-
-import net.corda.core.flows.FlowLogic;
-
-public class CamelFlow extends FlowLogic<String> {
- private String in;
-
- public CamelFlow(String in) {
- this.in = in;
- }
-
- @Override
- public String call() {
- return in + " world!";
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerITSupport.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerITSupport.java
deleted file mode 100644
index 8529c1d4e42..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerITSupport.java
+++ /dev/null
@@ -1,74 +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.corda;
-
-import net.corda.core.contracts.OwnableState;
-import net.corda.core.flows.FlowLogic;
-import net.corda.core.node.services.Vault;
-import net.corda.core.node.services.vault.PageSpecification;
-import net.corda.core.node.services.vault.QueryCriteria;
-import net.corda.core.node.services.vault.Sort;
-import net.corda.core.node.services.vault.SortAttribute;
-import org.apache.camel.BindToRegistry;
-
-import static net.corda.core.node.services.vault.QueryCriteriaUtils.DEFAULT_PAGE_NUM;
-import static net.corda.core.node.services.vault.QueryCriteriaUtils.MAX_PAGE_SIZE;
-
-public class CordaConsumerITSupport extends CordaITSupport {
-
- @Override
- public boolean isUseAdviceWith() {
- return false;
- }
-
- @BindToRegistry("arguments")
- public String[] addArgs() {
- String[] args = new String[] { "Hello" };
- return args;
- }
-
- @BindToRegistry("flowLociClass")
- public Class<FlowLogic<String>> addFlowLociClass() throws Exception {
- Class<FlowLogic<String>> flowLociClass
- = (Class<FlowLogic<String>>) Class.forName("org.apache.camel.component.corda.CamelFlow");
- return flowLociClass;
- }
-
- @BindToRegistry("queryCriteria")
- public QueryCriteria addCriteria() {
- QueryCriteria.VaultQueryCriteria criteria = new QueryCriteria.VaultQueryCriteria(Vault.StateStatus.CONSUMED);
- return criteria;
- }
-
- @BindToRegistry("pageSpecification")
- public PageSpecification addPageSpec() {
- PageSpecification pageSpec = new PageSpecification(DEFAULT_PAGE_NUM, MAX_PAGE_SIZE);
- return pageSpec;
- }
-
- @BindToRegistry("contractStateClass")
- public Class<OwnableState> addContractStateClass() {
- return OwnableState.class;
- }
-
- @BindToRegistry("sort")
- public Sort.SortColumn addSort() {
- Sort.SortColumn sortByUid
- = new Sort.SortColumn(new SortAttribute.Standard(Sort.LinearStateAttribute.UUID), Sort.Direction.DESC);
- return sortByUid;
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerNetworkMapFeedManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerNetworkMapFeedManualIT.java
deleted file mode 100644
index 0546f1b4d56..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerNetworkMapFeedManualIT.java
+++ /dev/null
@@ -1,48 +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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.NETWORK_MAP_FEED;
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerNetworkMapFeedManualIT extends CordaConsumerITSupport {
-
- @Test
- public void networkMapFeedTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + NETWORK_MAP_FEED)
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerStartTrackedFlowDynamicManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerStartTrackedFlowDynamicManualIT.java
deleted file mode 100644
index 66faed066b7..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerStartTrackedFlowDynamicManualIT.java
+++ /dev/null
@@ -1,53 +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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.START_TRACKED_FLOW_DYNAMIC;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerStartTrackedFlowDynamicManualIT extends CordaConsumerITSupport {
-
- @Test
- public void startTrackedFlowDynamicTest() throws Exception {
- //Expects CamelFlow is deployed on the node
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- assertEquals("Hello world!", mockResult.getExchanges().get(0).getIn().getBody());
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + START_TRACKED_FLOW_DYNAMIC
- + "&flowLociClass=#flowLociClass"
- + "&arguments=#arguments")
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerStateMachineFeedManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerStateMachineFeedManualIT.java
deleted file mode 100644
index 0a26ebfc778..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerStateMachineFeedManualIT.java
+++ /dev/null
@@ -1,48 +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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.STATE_MACHINE_FEED;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerStateMachineFeedManualIT extends CordaConsumerITSupport {
-
- @Test
- public void stateMachineFeedTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + STATE_MACHINE_FEED)
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerTransactionMapFeedManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerTransactionMapFeedManualIT.java
deleted file mode 100644
index 2f606a34506..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerTransactionMapFeedManualIT.java
+++ /dev/null
@@ -1,48 +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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerTransactionMapFeedManualIT extends CordaConsumerITSupport {
-
- @Test
- public void transactionMapFeedTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_FEED)
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByCriteriaManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByCriteriaManualIT.java
deleted file mode 100644
index abb83f142fd..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByCriteriaManualIT.java
+++ /dev/null
@@ -1,50 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY_CRITERIA;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerVaultTrackByCriteriaManualIT extends CordaConsumerITSupport {
-
- @Test
- public void vaultTrackByCriteriaTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + VAULT_TRACK_BY_CRITERIA
- + "&contractStateClass=#contractStateClass"
- + "&queryCriteria=#queryCriteria")
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByManualIT.java
deleted file mode 100644
index 4ff73026857..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByManualIT.java
+++ /dev/null
@@ -1,52 +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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerVaultTrackByManualIT extends CordaConsumerITSupport {
-
- @Test
- public void vaultTrackByTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + VAULT_TRACK_BY
- + "&contractStateClass=#contractStateClass"
- + "&queryCriteria=#queryCriteria"
- + "&pageSpecification=#pageSpecification"
- + "&sort=#sort")
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByWithPagingSpecManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByWithPagingSpecManualIT.java
deleted file mode 100644
index 8a222ee7ef1..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByWithPagingSpecManualIT.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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY_WITH_PAGING_SPEC;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerVaultTrackByWithPagingSpecManualIT extends CordaConsumerITSupport {
-
- @Test
- public void vaultTrackByWithPagingSpecTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + VAULT_TRACK_BY_WITH_PAGING_SPEC
- + "&contractStateClass=#contractStateClass"
- + "&queryCriteria=#queryCriteria"
- + "&pageSpecification=#pageSpecification")
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByWithSortingManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByWithSortingManualIT.java
deleted file mode 100644
index 74fdea78952..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackByWithSortingManualIT.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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK_BY_WITH_SORTING;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerVaultTrackByWithSortingManualIT extends CordaConsumerITSupport {
-
- @Test
- public void vaultTrackByWithSortingTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + VAULT_TRACK_BY_WITH_SORTING
- + "&contractStateClass=#contractStateClass"
- + "&queryCriteria=#queryCriteria"
- + "&sort=#sort")
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackManualIT.java
deleted file mode 100644
index e3ebc25f133..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaConsumerVaultTrackManualIT.java
+++ /dev/null
@@ -1,49 +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.corda;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-
-import static org.apache.camel.component.corda.CordaConstants.OPERATION;
-import static org.apache.camel.component.corda.CordaConstants.VAULT_TRACK;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaConsumerVaultTrackManualIT extends CordaConsumerITSupport {
-
- @Test
- public void vaultTrackTest() throws Exception {
- mockResult.expectedMinimumMessageCount(1);
- mockError.expectedMessageCount(0);
- MockEndpoint.assertIsSatisfied(context);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- errorHandler(deadLetterChannel("mock:error"));
-
- from(getUrl() + "&" + OPERATION.toLowerCase() + "=" + VAULT_TRACK
- + "&contractStateClass=#contractStateClass")
- .to("mock:result");
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaITSupport.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaITSupport.java
deleted file mode 100755
index a264fc8be40..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaITSupport.java
+++ /dev/null
@@ -1,67 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.corda;
-
-import org.apache.camel.EndpointInject;
-import org.apache.camel.Exchange;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.support.DefaultExchange;
-import org.apache.camel.test.junit5.CamelTestSupport;
-import org.junit.jupiter.api.AfterAll;
-import org.junit.jupiter.api.BeforeAll;
-import org.junit.jupiter.api.BeforeEach;
-import org.mockito.MockitoAnnotations;
-
-public class CordaITSupport extends CamelTestSupport {
-
- @EndpointInject("mock:result")
- protected MockEndpoint mockResult;
-
- @EndpointInject("mock:error")
- protected MockEndpoint mockError;
-
- @Override
- public boolean isUseAdviceWith() {
- return true;
- }
-
- protected String getUrl() {
- return "corda://localhost:10006?username=user1&password=test";
- }
-
- protected Exchange createExchangeWithBodyAndHeader(Object body, String key, Object value) {
- DefaultExchange exchange = new DefaultExchange(context);
- exchange.getIn().setBody(body);
- exchange.getIn().setHeader(key, value);
- return exchange;
- }
-
- @BeforeAll
- public static void startServer() {
- }
-
- @AfterAll
- public static void stopServer() {
- }
-
- @Override
- @BeforeEach
- public void setUp() throws Exception {
- MockitoAnnotations.initMocks(this);
- super.setUp();
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaProducerManualIT.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaProducerManualIT.java
deleted file mode 100644
index 78e059a1430..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/CordaProducerManualIT.java
+++ /dev/null
@@ -1,472 +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.corda;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.security.KeyPair;
-import java.security.KeyPairGenerator;
-import java.security.NoSuchAlgorithmException;
-import java.security.PublicKey;
-import java.util.zip.ZipEntry;
-import java.util.zip.ZipOutputStream;
-
-import com.google.common.collect.ImmutableSet;
-import net.corda.core.contracts.OwnableState;
-import net.corda.core.crypto.SecureHash;
-import net.corda.core.flows.FlowLogic;
-import net.corda.core.identity.AbstractParty;
-import net.corda.core.identity.AnonymousParty;
-import net.corda.core.identity.CordaX500Name;
-import net.corda.core.identity.Party;
-import net.corda.core.node.services.Vault;
-import net.corda.core.node.services.vault.AttachmentQueryCriteria;
-import net.corda.core.node.services.vault.AttachmentSort;
-import net.corda.core.node.services.vault.ColumnPredicate;
-import net.corda.core.node.services.vault.EqualityComparisonOperator;
-import net.corda.core.node.services.vault.PageSpecification;
-import net.corda.core.node.services.vault.QueryCriteria;
-import net.corda.core.node.services.vault.Sort;
-import net.corda.core.node.services.vault.SortAttribute;
-import org.apache.camel.Exchange;
-import org.apache.camel.Produce;
-import org.apache.camel.ProducerTemplate;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.jupiter.api.Disabled;
-import org.junit.jupiter.api.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import static net.corda.core.node.services.vault.QueryCriteriaUtils.DEFAULT_PAGE_NUM;
-import static net.corda.core.node.services.vault.QueryCriteriaUtils.MAX_PAGE_SIZE;
-import static org.apache.camel.component.corda.CordaConstants.*;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertNull;
-
-@Disabled("Requires manual steps to setup and run")
-public class CordaProducerManualIT extends CordaITSupport {
- private static final Logger LOG = LoggerFactory.getLogger(CordaProducerManualIT.class);
- private static final SecureHash.SHA256 TEST_SHA_256
- = SecureHash.parse("6D1687C143DF792A011A1E80670A4E4E0C25D0D87A39514409B1ABFC2043581F");
-
- @Produce("direct:start")
- protected ProducerTemplate template;
-
- @Override
- public boolean isUseAdviceWith() {
- return false;
- }
-
- @Test
- public void currentNodeTimeTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, CURRENT_NODE_TIME);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void getProtocolVersionTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, GET_PROTOCOL_VERSION);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void networkMapSnapshotTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, NETWORK_MAP_SNAPSHOT);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void stateMachinesSnapshotTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, STATE_MACHINE_SNAPSHOT);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void stateMachineRecordedTransactionMappingSnapshotTest() {
- Exchange exchange
- = createExchangeWithBodyAndHeader(null, OPERATION, STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_SNAPSHOT);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void registeredFlowsTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, REGISTERED_FLOWS);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void clearNetworkMapCacheTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, CLEAR_NETWORK_MAP_CACHE);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void isFlowsDrainingModeEnabledTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, IS_FLOWS_DRAINING_MODE_ENABLED);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void setFlowsDrainingModeEnabledTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, SET_FLOWS_DRAINING_MODE_ENABLED);
- exchange.getIn().setHeader(DRAINING_MODE, false);
- template.send(exchange);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void notaryIdentitiesTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, NOTARY_IDENTITIES);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void nodeInfoTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, NODE_INFO);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void addVaultTransactionNoteTest() {
- Exchange exchange = createExchangeWithBodyAndHeader("Some note", OPERATION, ADD_VAULT_TRANSACTION_NOTE);
-
- exchange.getIn().setHeader(SECURE_HASH, TEST_SHA_256);
- template.send(exchange);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void getVaultTransactionNotesTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, GET_VAULT_TRANSACTION_NOTES);
-
- exchange.getIn().setHeader(SECURE_HASH, TEST_SHA_256);
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void uploadAttachmentTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, UPLOAD_ATTACHMENT);
- exchange.getIn().setBody(zipIt("HELLO" + System.nanoTime(), "test1.txt"));
- template.send(exchange);
-
- Object body = exchange.getIn().getHeader(SECURE_HASH);
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void attachmentExistsTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, ATTACHMENT_EXISTS);
- exchange.getIn().setHeader(SECURE_HASH, TEST_SHA_256);
-
- template.send(exchange);
-
- Boolean body = exchange.getIn().getBody(Boolean.class);
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void openAttachmentTest() {
- //Setup node with attachment
- Exchange uploadExchange = createExchangeWithBodyAndHeader(null, OPERATION, UPLOAD_ATTACHMENT);
- uploadExchange.getIn().setBody(zipIt("HELLO" + System.nanoTime(), "test2.txt"));
- template.send(uploadExchange);
-
- Object hash = uploadExchange.getIn().getHeader(SECURE_HASH);
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, OPEN_ATTACHMENT);
- exchange.getIn().setHeader(SECURE_HASH, hash);
-
- template.send(exchange);
-
- InputStream body = exchange.getIn().getBody(InputStream.class);
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void queryAttachmentsTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, QUERY_ATTACHMENTS);
- AttachmentQueryCriteria.AttachmentsQueryCriteria queryCriteria = new AttachmentQueryCriteria.AttachmentsQueryCriteria(
- new ColumnPredicate.EqualityComparison(EqualityComparisonOperator.EQUAL, "Daredevil"));
- AttachmentSort attachmentSort = null;
-
- exchange.getIn().setHeader(ATTACHMENT_QUERY_CRITERIA, queryCriteria);
- exchange.getIn().setHeader(SORT, attachmentSort);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void nodeInfoFromPartyTest() throws Exception {
- //Expects IntegrationWhiteList is deployed on the node
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, NODE_INFO_FROM_PARTY);
- PublicKey pub = generatePublicKey();
- CordaX500Name cordaX500Name1 = new CordaX500Name("PartyA", "London", "GB");
- Party party = new Party(cordaX500Name1, pub);
- exchange.getIn().setBody(party);
-
- template.send(exchange);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void notaryPartyFromX500NameTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, NOTARY_PARTY_FROM_X500_NAME);
- CordaX500Name cordaX500Name = new CordaX500Name("Notary", "London", "GB");
- exchange.getIn().setBody(cordaX500Name);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void partiesFromNameTest() {
- Exchange exchange = createExchangeWithBodyAndHeader("A", OPERATION, PARTIES_FROM_NAME);
- exchange.getIn().setHeader(EXACT_MATCH, false);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void partyFromKeyTest() throws Exception {
- //Expects IntegrationWhiteList is deployed on the node
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, PARTIES_FROM_KEY);
- PublicKey pub = generatePublicKey();
- exchange.getIn().setBody(pub);
-
- template.send(exchange);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void wellKnownPartyFromX500NameTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, WELL_KNOWN_PARTY_FROM_X500_NAME);
- CordaX500Name cordaX500Name1 = new CordaX500Name("PartyA", "London", "GB");
- exchange.getIn().setBody(cordaX500Name1);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void wellKnownPartyFromAnonymousTest() throws Exception {
- //Expects IntegrationWhiteList is deployed on the node
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, WELL_KNOWN_PARTY_FROM_ANONYMOUS);
- PublicKey pub = generatePublicKey();
-
- AbstractParty party = new AnonymousParty(pub);
- exchange.getIn().setBody(party);
-
- template.send(exchange);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void startFlowDynamicTest() throws Exception {
- //Expects CamelFlow is deployed on the node
- Exchange exchange = createExchangeWithBodyAndHeader(null, OPERATION, START_FLOW_DYNAMIC);
- String[] args = new String[] { "Hello" };
- Class<FlowLogic<String>> aClass
- = (Class<FlowLogic<String>>) Class.forName("org.apache.camel.component.corda.CamelFlow");
- exchange.getIn().setBody(aClass);
- exchange.getIn().setHeader(ARGUMENTS, args);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- assertEquals("Hello world!", body.toString());
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void vaultQueryTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(OwnableState.class, OPERATION, VAULT_QUERY);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void vaultQueryByTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(OwnableState.class, OPERATION, VAULT_QUERY_BY);
- QueryCriteria.VaultQueryCriteria criteria = new QueryCriteria.VaultQueryCriteria(Vault.StateStatus.CONSUMED);
- PageSpecification pageSpec = new PageSpecification(DEFAULT_PAGE_NUM, MAX_PAGE_SIZE);
- Sort.SortColumn sortByUid
- = new Sort.SortColumn(new SortAttribute.Standard(Sort.LinearStateAttribute.UUID), Sort.Direction.DESC);
- Sort sorting = new Sort(ImmutableSet.of(sortByUid));
- exchange.getIn().setHeader(QUERY_CRITERIA, criteria);
- exchange.getIn().setHeader(PAGE_SPECIFICATION, pageSpec);
- exchange.getIn().setHeader(SORT, sorting);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void vaultQueryByCriteriaTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(OwnableState.class, OPERATION, VAULT_QUERY_BY_CRITERIA);
- QueryCriteria.VaultQueryCriteria criteria = new QueryCriteria.VaultQueryCriteria(Vault.StateStatus.CONSUMED);
- exchange.getIn().setHeader(QUERY_CRITERIA, criteria);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void vaultQueryByWithPagingSpecTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(OwnableState.class, OPERATION, VAULT_QUERY_BY_WITH_PAGING_SPEC);
- QueryCriteria.VaultQueryCriteria criteria = new QueryCriteria.VaultQueryCriteria(Vault.StateStatus.CONSUMED);
- PageSpecification pageSpec = new PageSpecification(DEFAULT_PAGE_NUM, MAX_PAGE_SIZE);
- exchange.getIn().setHeader(QUERY_CRITERIA, criteria);
- exchange.getIn().setHeader(PAGE_SPECIFICATION, pageSpec);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- @Test
- public void vaultQueryByWithSortingTest() {
- Exchange exchange = createExchangeWithBodyAndHeader(OwnableState.class, OPERATION, VAULT_QUERY_BY_WITH_SORTING);
- QueryCriteria.VaultQueryCriteria criteria = new QueryCriteria.VaultQueryCriteria(Vault.StateStatus.CONSUMED);
- Sort.SortColumn sortByUid
- = new Sort.SortColumn(new SortAttribute.Standard(Sort.LinearStateAttribute.UUID), Sort.Direction.DESC);
- Sort sorting = new Sort(ImmutableSet.of(sortByUid));
- exchange.getIn().setHeader(QUERY_CRITERIA, criteria);
- exchange.getIn().setHeader(SORT, sorting);
-
- template.send(exchange);
- Object body = exchange.getIn().getBody();
- assertNotNull(body);
- Object exception = exchange.getException();
- assertNull(exception);
- }
-
- private ByteArrayInputStream zipIt(String in, String name) {
- ByteArrayOutputStream baos = new ByteArrayOutputStream();
- try {
- ZipOutputStream zos = new ZipOutputStream(baos);
- ZipEntry entry = new ZipEntry(name);
- zos.putNextEntry(entry);
- zos.write(in.getBytes());
- zos.closeEntry();
- } catch (IOException ioe) {
- LOG.warn("I/O error while trying to compress stream: {}", ioe.getMessage(), ioe);
- }
-
- return new ByteArrayInputStream(baos.toByteArray());
- }
-
- private PublicKey generatePublicKey() throws NoSuchAlgorithmException {
- KeyPairGenerator kpg = KeyPairGenerator.getInstance("RSA");
- kpg.initialize(2048);
- KeyPair kp = kpg.generateKeyPair();
- return kp.getPublic();
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- public void configure() {
- from("direct:start")
- .to(getUrl());
- }
- };
- }
-}
diff --git a/components/camel-corda/src/test/java/org/apache/camel/component/corda/IntegrationWhiteList.java b/components/camel-corda/src/test/java/org/apache/camel/component/corda/IntegrationWhiteList.java
deleted file mode 100644
index 62b6f0b483e..00000000000
--- a/components/camel-corda/src/test/java/org/apache/camel/component/corda/IntegrationWhiteList.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.corda;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import net.corda.core.serialization.SerializationWhitelist;
-
-public class IntegrationWhiteList implements SerializationWhitelist {
-
- @Override
- public List<Class<?>> getWhitelist() {
- List list = new ArrayList();
- // list.add(RSAPublicKeyImpl.class);
- // list.add(AlgorithmId.class);
- // list.add(ObjectIdentifier.class);
- // list.add(BitArray.class);
- // list.add(BigInteger.class);
- return list;
- }
-}
diff --git a/components/camel-corda/src/test/resources/META-INF/services/net.corda.core.serialization.SerializationWhitelist b/components/camel-corda/src/test/resources/META-INF/services/net.corda.core.serialization.SerializationWhitelist
deleted file mode 100644
index 8c42a02ebee..00000000000
--- a/components/camel-corda/src/test/resources/META-INF/services/net.corda.core.serialization.SerializationWhitelist
+++ /dev/null
@@ -1 +0,0 @@
-org.apache.camel.component.corda.IntegrationWhiteList
diff --git a/components/camel-corda/src/test/resources/log4j2.properties b/components/camel-corda/src/test/resources/log4j2.properties
deleted file mode 100644
index 952c0fb4796..00000000000
--- a/components/camel-corda/src/test/resources/log4j2.properties
+++ /dev/null
@@ -1,34 +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.
-## ---------------------------------------------------------------------------
-rootLogger.level = DEBUG
-rootLogger.appenderRef.file.ref = file
-
-appender.file.type = File
-appender.file.name = file
-appender.file.fileName = target/camel-corda-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.org.fabric=DEBUG
-#rootLogger.org.apache.http=DEBUG
-
-
diff --git a/components/camel-corda/src/test/resources/mockito-extensions/org.mockito.plugins.MockMaker b/components/camel-corda/src/test/resources/mockito-extensions/org.mockito.plugins.MockMaker
deleted file mode 100644
index ca6ee9cea8e..00000000000
--- a/components/camel-corda/src/test/resources/mockito-extensions/org.mockito.plugins.MockMaker
+++ /dev/null
@@ -1 +0,0 @@
-mock-maker-inline
\ No newline at end of file
diff --git a/components/pom.xml b/components/pom.xml
index c360ceb510c..0feded22eac 100644
--- a/components/pom.xml
+++ b/components/pom.xml
@@ -104,7 +104,6 @@
<module>camel-coap</module>
<module>camel-cometd</module>
<module>camel-consul</module>
- <module>camel-corda</module>
<module>camel-couchbase</module>
<module>camel-couchdb</module>
<module>camel-crypto</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 adb6490da35..df192153050 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
@@ -58,7 +58,6 @@ cometd
cometds
consul
controlbus
-corda
couchbase
couchdb
cql
diff --git a/docs/components/modules/ROOT/nav.adoc b/docs/components/modules/ROOT/nav.adoc
index f3d5c4c8741..b70bb75b47e 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -61,7 +61,6 @@
** xref:cometd-component.adoc[CometD]
** xref:consul-component.adoc[Consul]
** xref:controlbus-component.adoc[Control Bus]
-** xref:corda-component.adoc[Corda]
** xref:couchbase-component.adoc[Couchbase]
** xref:couchdb-component.adoc[CouchDB]
** xref:cron-component.adoc[Cron]
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 2d72f48fa7a..3ca6a29196d 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
@@ -836,20 +836,6 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.ControlbusComponentBuilderFactory.ControlbusComponentBuilder controlbus() {
return org.apache.camel.builder.component.dsl.ControlbusComponentBuilderFactory.controlbus();
}
- /**
- * Corda (camel-corda)
- * Perform operations against Corda blockchain platform using corda-rpc
- * library.
- *
- * Category: blockchain,rpc
- * Since: 2.23
- * Maven coordinates: org.apache.camel:camel-corda
- *
- * @return the dsl builder
- */
- static org.apache.camel.builder.component.dsl.CordaComponentBuilderFactory.CordaComponentBuilder corda() {
- return org.apache.camel.builder.component.dsl.CordaComponentBuilderFactory.corda();
- }
/**
* Couchbase (camel-couchbase)
* Query Couchbase Views with a poll strategy and/or perform various
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/CordaComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/CordaComponentBuilderFactory.java
deleted file mode 100644
index 48c016e4c87..00000000000
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/CordaComponentBuilderFactory.java
+++ /dev/null
@@ -1,352 +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.corda.CordaComponent;
-
-/**
- * Perform operations against Corda blockchain platform using corda-rpc library.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface CordaComponentBuilderFactory {
-
- /**
- * Corda (camel-corda)
- * Perform operations against Corda blockchain platform using corda-rpc
- * library.
- *
- * Category: blockchain,rpc
- * Since: 2.23
- * Maven coordinates: org.apache.camel:camel-corda
- *
- * @return the dsl builder
- */
- static CordaComponentBuilder corda() {
- return new CordaComponentBuilderImpl();
- }
-
- /**
- * Builder for the Corda component.
- */
- interface CordaComponentBuilder extends ComponentBuilder<CordaComponent> {
- /**
- * To use a shared configuration.
- *
- * The option is a:
- * <code>org.apache.camel.component.corda.CordaConfiguration</code> type.
- *
- * Group: common
- *
- * @param configuration the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder configuration(
- org.apache.camel.component.corda.CordaConfiguration configuration) {
- doSetProperty("configuration", configuration);
- 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 is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * PageSpecification allows specification of a page number (starting
- * from 1) and page size (defaulting to 200 with a maximum page size of
- * (Integer.MAX_INT) Note: we default the page number to 200 to enable
- * queries without requiring a page specification but enabling detection
- * of large results sets that fall out of the 200 requirement. Max page
- * size should be used with extreme caution as results may exceed your
- * JVM memory footprint.
- *
- * The option is a:
- * <code>net.corda.core.node.services.vault.PageSpecification</code> type.
- *
- * Default: 200
- * Group: consumer
- *
- * @param pageSpecification the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder pageSpecification(
- net.corda.core.node.services.vault.PageSpecification pageSpecification) {
- doSetProperty("pageSpecification", pageSpecification);
- return this;
- }
- /**
- * Whether to process snapshots or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: consumer
- *
- * @param processSnapshot the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder processSnapshot(boolean processSnapshot) {
- doSetProperty("processSnapshot", processSnapshot);
- return this;
- }
- /**
- * Sort allows specification of a set of entity attribute names and
- * their associated directionality and null handling, to be applied upon
- * processing a query specification.
- *
- * The option is a:
- * <code>net.corda.core.node.services.vault.Sort</code>
- * type.
- *
- * Group: consumer
- *
- * @param sort the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder sort(
- net.corda.core.node.services.vault.Sort sort) {
- doSetProperty("sort", sort);
- return this;
- }
- /**
- * A contract state (or just state) contains opaque data used by a
- * contract program. It can be thought of as a disk file that the
- * program can use to persist data across transactions. States are
- * immutable: once created they are never updated, instead, any changes
- * must generate a new successor state. States can be updated (consumed)
- * only once: the notary is responsible for ensuring there is no double
- * spending by only signing a transaction if the input states are all
- * free.
- *
- * The option is a:
- * <code>java.lang.Class&lt;net.corda.core.contracts.ContractState&gt;</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param contractStateClass the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder contractStateClass(
- java.lang.Class<net.corda.core.contracts.ContractState> contractStateClass) {
- doSetProperty("contractStateClass", contractStateClass);
- return this;
- }
- /**
- * Start the given flow with the given arguments, returning an
- * Observable with a single observation of the result of running the
- * flow. The flowLogicClass must be annotated with
- * net.corda.core.flows.StartableByRPC.
- *
- * The option is a: <code>java.lang.Object[]</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param flowLogicArguments the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder flowLogicArguments(
- java.lang.Object[] flowLogicArguments) {
- doSetProperty("flowLogicArguments", flowLogicArguments);
- return this;
- }
- /**
- * Start the given flow with the given arguments, returning an
- * Observable with a single observation of the result of running the
- * flow. The flowLogicClass must be annotated with
- * net.corda.core.flows.StartableByRPC.
- *
- * The option is a:
- * <code>java.lang.Class&lt;net.corda.core.flows.FlowLogic&lt;java.lang.Object&gt;&gt;</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param flowLogicClass the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder flowLogicClass(
- java.lang.Class<net.corda.core.flows.FlowLogic<java.lang.Object>> flowLogicClass) {
- doSetProperty("flowLogicClass", flowLogicClass);
- return this;
- }
- /**
- * QueryCriteria assumes underlying schema tables are correctly indexed
- * for performance.
- *
- * The option is a:
- * <code>net.corda.core.node.services.vault.QueryCriteria</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param queryCriteria the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder queryCriteria(
- net.corda.core.node.services.vault.QueryCriteria queryCriteria) {
- doSetProperty("queryCriteria", queryCriteria);
- 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 CordaComponentBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * Operation to use.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param operation the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder operation(java.lang.String operation) {
- doSetProperty("operation", operation);
- 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 CordaComponentBuilder autowiredEnabled(boolean autowiredEnabled) {
- doSetProperty("autowiredEnabled", autowiredEnabled);
- return this;
- }
- /**
- * Password for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param password the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder password(java.lang.String password) {
- doSetProperty("password", password);
- return this;
- }
- /**
- * Username for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param username the value to set
- * @return the dsl builder
- */
- default CordaComponentBuilder username(java.lang.String username) {
- doSetProperty("username", username);
- return this;
- }
- }
-
- class CordaComponentBuilderImpl
- extends
- AbstractComponentBuilder<CordaComponent>
- implements
- CordaComponentBuilder {
- @Override
- protected CordaComponent buildConcreteComponent() {
- return new CordaComponent();
- }
- private org.apache.camel.component.corda.CordaConfiguration getOrCreateConfiguration(
- org.apache.camel.component.corda.CordaComponent component) {
- if (component.getConfiguration() == null) {
- component.setConfiguration(new org.apache.camel.component.corda.CordaConfiguration());
- }
- return component.getConfiguration();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "configuration": ((CordaComponent) component).setConfiguration((org.apache.camel.component.corda.CordaConfiguration) value); return true;
- case "bridgeErrorHandler": ((CordaComponent) component).setBridgeErrorHandler((boolean) value); return true;
- case "pageSpecification": getOrCreateConfiguration((CordaComponent) component).setPageSpecification((net.corda.core.node.services.vault.PageSpecification) value); return true;
- case "processSnapshot": getOrCreateConfiguration((CordaComponent) component).setProcessSnapshot((boolean) value); return true;
- case "sort": getOrCreateConfiguration((CordaComponent) component).setSort((net.corda.core.node.services.vault.Sort) value); return true;
- case "contractStateClass": getOrCreateConfiguration((CordaComponent) component).setContractStateClass((java.lang.Class) value); return true;
- case "flowLogicArguments": getOrCreateConfiguration((CordaComponent) component).setFlowLogicArguments((java.lang.Object[]) value); return true;
- case "flowLogicClass": getOrCreateConfiguration((CordaComponent) component).setFlowLogicClass((java.lang.Class) value); return true;
- case "queryCriteria": getOrCreateConfiguration((CordaComponent) component).setQueryCriteria((net.corda.core.node.services.vault.QueryCriteria) value); return true;
- case "lazyStartProducer": ((CordaComponent) component).setLazyStartProducer((boolean) value); return true;
- case "operation": getOrCreateConfiguration((CordaComponent) component).setOperation((java.lang.String) value); return true;
- case "autowiredEnabled": ((CordaComponent) component).setAutowiredEnabled((boolean) value); return true;
- case "password": getOrCreateConfiguration((CordaComponent) component).setPassword((java.lang.String) value); return true;
- case "username": getOrCreateConfiguration((CordaComponent) component).setUsername((java.lang.String) value); return true;
- default: return false;
- }
- }
- }
-}
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/resources/metadata.json b/dsl/camel-componentdsl/src/generated/resources/metadata.json
index d95ddd1f19c..1718efe42ae 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -1332,28 +1332,6 @@
"producerOnly": true,
"lenientProperties": false
},
- "CordaComponentBuilderFactory": {
- "kind": "component",
- "name": "corda",
- "title": "Corda",
- "description": "Perform operations against Corda blockchain platform using corda-rpc library.",
- "deprecated": false,
- "firstVersion": "2.23.0",
- "label": "blockchain,rpc",
- "javaType": "org.apache.camel.component.corda.CordaComponent",
- "supportLevel": "Stable",
- "groupId": "org.apache.camel",
- "artifactId": "camel-corda",
- "version": "4.0.0-SNAPSHOT",
- "scheme": "corda",
- "extendsScheme": "",
- "syntax": "corda:node",
- "async": false,
- "api": false,
- "consumerOnly": false,
- "producerOnly": false,
- "lenientProperties": false
- },
"CouchbaseComponentBuilderFactory": {
"kind": "component",
"name": "couchbase",
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 b611bcfa0eb..c281b59a419 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
@@ -60,7 +60,6 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.CometdEndpointBuilderFactory.CometdBuilders,
org.apache.camel.builder.endpoint.dsl.ConsulEndpointBuilderFactory.ConsulBuilders,
org.apache.camel.builder.endpoint.dsl.ControlBusEndpointBuilderFactory.ControlBusBuilders,
- org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory.CordaBuilders,
org.apache.camel.builder.endpoint.dsl.CosmosDbEndpointBuilderFactory.CosmosDbBuilders,
org.apache.camel.builder.endpoint.dsl.CouchDbEndpointBuilderFactory.CouchDbBuilders,
org.apache.camel.builder.endpoint.dsl.CouchbaseEndpointBuilderFactory.CouchbaseBuilders,
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 259f53339b9..3f9a00b3a39 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
@@ -57,7 +57,6 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.CometdEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ConsulEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.ControlBusEndpointBuilderFactory,
- org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CosmosDbEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CouchDbEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.CouchbaseEndpointBuilderFactory,
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 39d7af00342..cffa7de6fc5 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
@@ -2686,51 +2686,6 @@ public class StaticEndpointBuilders {
String path) {
return org.apache.camel.builder.endpoint.dsl.ControlBusEndpointBuilderFactory.endpointBuilder(componentName, path);
}
- /**
- * Corda (camel-corda)
- * Perform operations against Corda blockchain platform using corda-rpc
- * library.
- *
- * Category: blockchain,rpc
- * Since: 2.23
- * Maven coordinates: org.apache.camel:camel-corda
- *
- * Syntax: <code>corda:node</code>
- *
- * Path parameter: node (required)
- * The url for the corda node
- *
- * @param path node
- * @return the dsl builder
- */
- public static org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory.CordaEndpointBuilder corda(
- String path) {
- return org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory.endpointBuilder("corda", path);
- }
- /**
- * Corda (camel-corda)
- * Perform operations against Corda blockchain platform using corda-rpc
- * library.
- *
- * Category: blockchain,rpc
- * Since: 2.23
- * Maven coordinates: org.apache.camel:camel-corda
- *
- * Syntax: <code>corda:node</code>
- *
- * Path parameter: node (required)
- * The url for the corda node
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path node
- * @return the dsl builder
- */
- public static org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory.CordaEndpointBuilder corda(
- String componentName,
- String path) {
- return org.apache.camel.builder.endpoint.dsl.CordaEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
/**
* Couchbase (camel-couchbase)
* Query Couchbase Views with a poll strategy and/or perform various
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/CordaEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/CordaEndpointBuilderFactory.java
deleted file mode 100644
index b21673351cc..00000000000
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/CordaEndpointBuilderFactory.java
+++ /dev/null
@@ -1,839 +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;
-
-/**
- * Perform operations against Corda blockchain platform using corda-rpc library.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface CordaEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint consumers for the Corda component.
- */
- public interface CordaEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default AdvancedCordaEndpointConsumerBuilder advanced() {
- return (AdvancedCordaEndpointConsumerBuilder) this;
- }
- /**
- * PageSpecification allows specification of a page number (starting
- * from 1) and page size (defaulting to 200 with a maximum page size of
- * (Integer.MAX_INT) Note: we default the page number to 200 to enable
- * queries without requiring a page specification but enabling detection
- * of large results sets that fall out of the 200 requirement. Max page
- * size should be used with extreme caution as results may exceed your
- * JVM memory footprint.
- *
- * The option is a:
- * <code>net.corda.core.node.services.vault.PageSpecification</code> type.
- *
- * Default: 200
- * Group: consumer
- *
- * @param pageSpecification the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder pageSpecification(
- net.corda.core.node.services.vault.PageSpecification pageSpecification) {
- doSetProperty("pageSpecification", pageSpecification);
- return this;
- }
- /**
- * PageSpecification allows specification of a page number (starting
- * from 1) and page size (defaulting to 200 with a maximum page size of
- * (Integer.MAX_INT) Note: we default the page number to 200 to enable
- * queries without requiring a page specification but enabling detection
- * of large results sets that fall out of the 200 requirement. Max page
- * size should be used with extreme caution as results may exceed your
- * JVM memory footprint.
- *
- * The option will be converted to a
- * <code>net.corda.core.node.services.vault.PageSpecification</code> type.
- *
- * Default: 200
- * Group: consumer
- *
- * @param pageSpecification the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder pageSpecification(
- String pageSpecification) {
- doSetProperty("pageSpecification", pageSpecification);
- return this;
- }
- /**
- * Whether to process snapshots or not.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: consumer
- *
- * @param processSnapshot the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder processSnapshot(
- boolean processSnapshot) {
- doSetProperty("processSnapshot", processSnapshot);
- return this;
- }
- /**
- * Whether to process snapshots or not.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: consumer
- *
- * @param processSnapshot the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder processSnapshot(
- String processSnapshot) {
- doSetProperty("processSnapshot", processSnapshot);
- return this;
- }
- /**
- * Sort allows specification of a set of entity attribute names and
- * their associated directionality and null handling, to be applied upon
- * processing a query specification.
- *
- * The option is a:
- * <code>net.corda.core.node.services.vault.Sort</code>
- * type.
- *
- * Group: consumer
- *
- * @param sort the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder sort(
- net.corda.core.node.services.vault.Sort sort) {
- doSetProperty("sort", sort);
- return this;
- }
- /**
- * Sort allows specification of a set of entity attribute names and
- * their associated directionality and null handling, to be applied upon
- * processing a query specification.
- *
- * The option will be converted to a
- * <code>net.corda.core.node.services.vault.Sort</code>
- * type.
- *
- * Group: consumer
- *
- * @param sort the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder sort(String sort) {
- doSetProperty("sort", sort);
- return this;
- }
- /**
- * Password for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param password the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder password(String password) {
- doSetProperty("password", password);
- return this;
- }
- /**
- * Username for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param username the value to set
- * @return the dsl builder
- */
- default CordaEndpointConsumerBuilder username(String username) {
- doSetProperty("username", username);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint consumers for the Corda component.
- */
- public interface AdvancedCordaEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default CordaEndpointConsumerBuilder basic() {
- return (CordaEndpointConsumerBuilder) 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 AdvancedCordaEndpointConsumerBuilder 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 AdvancedCordaEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * A contract state (or just state) contains opaque data used by a
- * contract program. It can be thought of as a disk file that the
- * program can use to persist data across transactions. States are
- * immutable: once created they are never updated, instead, any changes
- * must generate a new successor state. States can be updated (consumed)
- * only once: the notary is responsible for ensuring there is no double
- * spending by only signing a transaction if the input states are all
- * free.
- *
- * The option is a:
- * <code>java.lang.Class&lt;net.corda.core.contracts.ContractState&gt;</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param contractStateClass the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder contractStateClass(
- Class<net.corda.core.contracts.ContractState> contractStateClass) {
- doSetProperty("contractStateClass", contractStateClass);
- return this;
- }
- /**
- * A contract state (or just state) contains opaque data used by a
- * contract program. It can be thought of as a disk file that the
- * program can use to persist data across transactions. States are
- * immutable: once created they are never updated, instead, any changes
- * must generate a new successor state. States can be updated (consumed)
- * only once: the notary is responsible for ensuring there is no double
- * spending by only signing a transaction if the input states are all
- * free.
- *
- * The option will be converted to a
- * <code>java.lang.Class&lt;net.corda.core.contracts.ContractState&gt;</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param contractStateClass the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder contractStateClass(
- String contractStateClass) {
- doSetProperty("contractStateClass", contractStateClass);
- 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 AdvancedCordaEndpointConsumerBuilder 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 AdvancedCordaEndpointConsumerBuilder 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 AdvancedCordaEndpointConsumerBuilder 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 AdvancedCordaEndpointConsumerBuilder exchangePattern(
- String exchangePattern) {
- doSetProperty("exchangePattern", exchangePattern);
- return this;
- }
- /**
- * Start the given flow with the given arguments, returning an
- * Observable with a single observation of the result of running the
- * flow. The flowLogicClass must be annotated with
- * net.corda.core.flows.StartableByRPC.
- *
- * The option is a: <code>java.lang.Object[]</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param flowLogicArguments the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder flowLogicArguments(
- Object[] flowLogicArguments) {
- doSetProperty("flowLogicArguments", flowLogicArguments);
- return this;
- }
- /**
- * Start the given flow with the given arguments, returning an
- * Observable with a single observation of the result of running the
- * flow. The flowLogicClass must be annotated with
- * net.corda.core.flows.StartableByRPC.
- *
- * The option will be converted to a
- * <code>java.lang.Object[]</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param flowLogicArguments the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder flowLogicArguments(
- String flowLogicArguments) {
- doSetProperty("flowLogicArguments", flowLogicArguments);
- return this;
- }
- /**
- * Start the given flow with the given arguments, returning an
- * Observable with a single observation of the result of running the
- * flow. The flowLogicClass must be annotated with
- * net.corda.core.flows.StartableByRPC.
- *
- * The option is a:
- * <code>java.lang.Class&lt;net.corda.core.flows.FlowLogic&lt;java.lang.Object&gt;&gt;</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param flowLogicClass the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder flowLogicClass(
- Class<net.corda.core.flows.FlowLogic<java.lang.Object>> flowLogicClass) {
- doSetProperty("flowLogicClass", flowLogicClass);
- return this;
- }
- /**
- * Start the given flow with the given arguments, returning an
- * Observable with a single observation of the result of running the
- * flow. The flowLogicClass must be annotated with
- * net.corda.core.flows.StartableByRPC.
- *
- * The option will be converted to a
- * <code>java.lang.Class&lt;net.corda.core.flows.FlowLogic&lt;java.lang.Object&gt;&gt;</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param flowLogicClass the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder flowLogicClass(
- String flowLogicClass) {
- doSetProperty("flowLogicClass", flowLogicClass);
- return this;
- }
- /**
- * QueryCriteria assumes underlying schema tables are correctly indexed
- * for performance.
- *
- * The option is a:
- * <code>net.corda.core.node.services.vault.QueryCriteria</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param queryCriteria the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder queryCriteria(
- net.corda.core.node.services.vault.QueryCriteria queryCriteria) {
- doSetProperty("queryCriteria", queryCriteria);
- return this;
- }
- /**
- * QueryCriteria assumes underlying schema tables are correctly indexed
- * for performance.
- *
- * The option will be converted to a
- * <code>net.corda.core.node.services.vault.QueryCriteria</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param queryCriteria the value to set
- * @return the dsl builder
- */
- default AdvancedCordaEndpointConsumerBuilder queryCriteria(
- String queryCriteria) {
- doSetProperty("queryCriteria", queryCriteria);
- return this;
- }
- }
-
- /**
- * Builder for endpoint producers for the Corda component.
- */
- public interface CordaEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedCordaEndpointProducerBuilder advanced() {
- return (AdvancedCordaEndpointProducerBuilder) this;
- }
- /**
- * Operation to use.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param operation the value to set
- * @return the dsl builder
- */
- default CordaEndpointProducerBuilder operation(String operation) {
- doSetProperty("operation", operation);
- return this;
- }
- /**
- * Password for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param password the value to set
- * @return the dsl builder
- */
- default CordaEndpointProducerBuilder password(String password) {
- doSetProperty("password", password);
- return this;
- }
- /**
- * Username for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param username the value to set
- * @return the dsl builder
- */
- default CordaEndpointProducerBuilder username(String username) {
- doSetProperty("username", username);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint producers for the Corda component.
- */
- public interface AdvancedCordaEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default CordaEndpointProducerBuilder basic() {
- return (CordaEndpointProducerBuilder) 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 AdvancedCordaEndpointProducerBuilder 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 AdvancedCordaEndpointProducerBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- }
-
- /**
- * Builder for endpoint for the Corda component.
- */
- public interface CordaEndpointBuilder
- extends
- CordaEndpointConsumerBuilder,
- CordaEndpointProducerBuilder {
- default AdvancedCordaEndpointBuilder advanced() {
- return (AdvancedCordaEndpointBuilder) this;
- }
- /**
- * Password for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param password the value to set
- * @return the dsl builder
- */
- default CordaEndpointBuilder password(String password) {
- doSetProperty("password", password);
- return this;
- }
- /**
- * Username for login.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: security
- *
- * @param username the value to set
- * @return the dsl builder
- */
- default CordaEndpointBuilder username(String username) {
- doSetProperty("username", username);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the Corda component.
- */
- public interface AdvancedCordaEndpointBuilder
- extends
- AdvancedCordaEndpointConsumerBuilder,
- AdvancedCordaEndpointProducerBuilder {
- default CordaEndpointBuilder basic() {
- return (CordaEndpointBuilder) this;
- }
- }
-
- public interface CordaBuilders {
- /**
- * Corda (camel-corda)
- * Perform operations against Corda blockchain platform using corda-rpc
- * library.
- *
- * Category: blockchain,rpc
- * Since: 2.23
- * Maven coordinates: org.apache.camel:camel-corda
- *
- * @return the dsl builder for the headers' name.
- */
- default CordaHeaderNameBuilder corda() {
- return CordaHeaderNameBuilder.INSTANCE;
- }
- /**
- * Corda (camel-corda)
- * Perform operations against Corda blockchain platform using corda-rpc
- * library.
- *
- * Category: blockchain,rpc
- * Since: 2.23
- * Maven coordinates: org.apache.camel:camel-corda
- *
- * Syntax: <code>corda:node</code>
- *
- * Path parameter: node (required)
- * The url for the corda node
- *
- * @param path node
- * @return the dsl builder
- */
- default CordaEndpointBuilder corda(String path) {
- return CordaEndpointBuilderFactory.endpointBuilder("corda", path);
- }
- /**
- * Corda (camel-corda)
- * Perform operations against Corda blockchain platform using corda-rpc
- * library.
- *
- * Category: blockchain,rpc
- * Since: 2.23
- * Maven coordinates: org.apache.camel:camel-corda
- *
- * Syntax: <code>corda:node</code>
- *
- * Path parameter: node (required)
- * The url for the corda node
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path node
- * @return the dsl builder
- */
- default CordaEndpointBuilder corda(String componentName, String path) {
- return CordaEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
-
- /**
- * The builder of headers' name for the Corda component.
- */
- public static class CordaHeaderNameBuilder {
- /**
- * The internal instance of the builder used to access to all the
- * methods representing the name of headers.
- */
- private static final CordaHeaderNameBuilder INSTANCE = new CordaHeaderNameBuilder();
-
- /**
- * The operation to perform.
- *
- * The option is a: {@code String} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code OPERATION}.
- */
- public String oPERATION() {
- return "OPERATION";
- }
-
- /**
- * The attachment query criteria.
- *
- * The option is a: {@code
- * net.corda.core.node.services.vault.AttachmentQueryCriteria} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code ATTACHMENT_QUERY_CRITERIA}.
- */
- public String attachmentQueryCriteria() {
- return "ATTACHMENT_QUERY_CRITERIA";
- }
-
- /**
- * The sort.
- *
- * The option is a: {@code } type.
- *
- * Group: producer
- *
- * @return the name of the header {@code SORT}.
- */
- public String sORT() {
- return "SORT";
- }
-
- /**
- * If true, a case sensitive match is done against each component of
- * each X.500 name.
- *
- * The option is a: {@code Boolean} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code EXACT_MATCH}.
- */
- public String exactMatch() {
- return "EXACT_MATCH";
- }
-
- /**
- * The arguments.
- *
- * The option is a: {@code Object[]} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code ARGUMENTS}.
- */
- public String aRGUMENTS() {
- return "ARGUMENTS";
- }
-
- /**
- * The value of the node's flows draining mode.
- *
- * The option is a: {@code Boolean} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code DRAINING_MODE}.
- */
- public String drainingMode() {
- return "DRAINING_MODE";
- }
-
- /**
- * Container for a cryptographically secure hash value.
- *
- * The option is a: {@code net.corda.core.crypto.SecureHash} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code SECURE_HASH}.
- */
- public String secureHash() {
- return "SECURE_HASH";
- }
-
- /**
- * The query criteria.
- *
- * The option is a: {@code
- * net.corda.core.node.services.vault.QueryCriteria} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code QUERY_CRITERIA}.
- */
- public String queryCriteria() {
- return "QUERY_CRITERIA";
- }
-
- /**
- * The PageSpecification allows specification of a page number and page
- * size.
- *
- * The option is a: {@code
- * net.corda.core.node.services.vault.PageSpecification} type.
- *
- * Group: producer
- *
- * @return the name of the header {@code PAGE_SPECIFICATION}.
- */
- public String pageSpecification() {
- return "PAGE_SPECIFICATION";
- }
- }
- static CordaEndpointBuilder endpointBuilder(
- String componentName,
- String path) {
- class CordaEndpointBuilderImpl extends AbstractEndpointBuilder implements CordaEndpointBuilder, AdvancedCordaEndpointBuilder {
- public CordaEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new CordaEndpointBuilderImpl(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 82ebd8cd834..8f92737ce8e 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
@@ -72,7 +72,6 @@ org.apache.camel.component.cm.CMComponent=camel:cm-sms
org.apache.camel.component.cometd.CometdComponent=camel:cometd
org.apache.camel.component.consul.ConsulComponent=camel:consul
org.apache.camel.component.controlbus.ControlBusComponent=camel:controlbus
-org.apache.camel.component.corda.CordaComponent=camel:corda
org.apache.camel.component.couchbase.CouchbaseComponent=camel:couchbase
org.apache.camel.component.couchdb.CouchDbComponent=camel:couchdb
org.apache.camel.component.cron.CronComponent=camel:cron
diff --git a/parent/pom.xml b/parent/pom.xml
index 3d00b6da3bc..a6ef5808437 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -115,7 +115,6 @@
<compress-lzf-version>1.1.2</compress-lzf-version>
<consul-client-version>1.5.3</consul-client-version>
<cobertura-maven-plugin-version>2.7</cobertura-maven-plugin-version>
- <corda-version>4.10</corda-version>
<couchbase-client-version>3.4.8</couchbase-client-version>
<curator-version>5.5.0</curator-version>
<cxf-version>4.0.2</cxf-version>
@@ -977,11 +976,6 @@
<artifactId>camel-controlbus</artifactId>
<version>${project.version}</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-corda</artifactId>
- <version>${project.version}</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-couchbase</artifactId>