This is an automated email from the ASF dual-hosted git repository. oscerd pushed a commit to branch fix/2828 in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 37de081a727ae16bb909c6472e522bbd06abf1e0 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed May 13 11:36:22 2026 +0200 Fix #2828: Consolidate JMS AMQP 10 SSL variants into single kamelets Remove separate jms-amqp-10-ssl-source and jms-amqp-10-ssl-sink kamelets and consolidate SSL/TLS support into the existing jms-amqp-10-source and jms-amqp-10-sink kamelets. SSL is handled by the Qpid JMS client via the amqps:// URI scheme, so separate kamelets are unnecessary. Co-Authored-By: Claude Opus 4.6 (1M context) <[email protected]> Signed-off-by: Andrea Cosentino <[email protected]> --- docs/modules/ROOT/nav.adoc | 2 - .../partials/jms-amqp-10-ssl-sink-description.adoc | 24 -------- .../jms-amqp-10-ssl-source-description.adoc | 53 ---------------- kamelets/jms-amqp-10-sink.kamelet.yaml | 4 +- kamelets/jms-amqp-10-source.kamelet.yaml | 4 +- kamelets/jms-amqp-10-ssl-sink.kamelet.yaml | 70 ---------------------- kamelets/jms-amqp-10-ssl-source.kamelet.yaml | 70 ---------------------- .../catalog/model/KameletPrefixSchemeEnum.java | 1 - .../kamelets/catalog/KameletsCatalogTest.java | 2 - .../kamelets/jms-amqp-10-sink.kamelet.yaml | 4 +- .../kamelets/jms-amqp-10-source.kamelet.yaml | 4 +- .../kamelets/jms-amqp-10-ssl-sink.kamelet.yaml | 70 ---------------------- .../kamelets/jms-amqp-10-ssl-source.kamelet.yaml | 70 ---------------------- .../pipes/camel-k/jms-amqp-10-ssl-sink-pipe.yaml | 18 ------ .../pipes/camel-k/jms-amqp-10-ssl-source-pipe.yaml | 18 ------ .../pipes/core/jms-amqp-10-ssl-sink-pipe.yaml | 12 ---- .../pipes/core/jms-amqp-10-ssl-source-pipe.yaml | 9 --- 17 files changed, 8 insertions(+), 427 deletions(-) diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc index 338abe910..eeff133c2 100644 --- a/docs/modules/ROOT/nav.adoc +++ b/docs/modules/ROOT/nav.adoc @@ -130,8 +130,6 @@ * xref:jira-update-issue-sink.adoc[] * xref:jms-amqp-10-sink.adoc[] * xref:jms-amqp-10-source.adoc[] -* xref:jms-amqp-10-ssl-sink.adoc[] -* xref:jms-amqp-10-ssl-source.adoc[] * xref:jms-apache-artemis-sink.adoc[] * xref:jms-apache-artemis-source.adoc[] * xref:jms-ibm-mq-sink.adoc[] diff --git a/docs/modules/ROOT/partials/jms-amqp-10-ssl-sink-description.adoc b/docs/modules/ROOT/partials/jms-amqp-10-ssl-sink-description.adoc deleted file mode 100644 index fa6e3a673..000000000 --- a/docs/modules/ROOT/partials/jms-amqp-10-ssl-sink-description.adoc +++ /dev/null @@ -1,24 +0,0 @@ -== JMS - AMQP 1.0 SSL Sink Kamelet Description - -=== Connection Configuration - -This Kamelet connects to any AMQP 1.0 compliant message broker over an SSL/TLS connection using the Apache Qpid JMS client. - -=== SSL/TLS Configuration - -SSL transport options are configured as query parameters on the `remoteURI`. Common options include: - -- `transport.trustStoreLocation`: Path to the truststore file -- `transport.trustStorePassword`: Password for the truststore -- `transport.keyStoreLocation`: Path to the keystore file -- `transport.keyStorePassword`: Password for the keystore -- `transport.verifyHost`: Verify hostname matches certificate (default: true) -- `transport.trustAll`: Trust server certificate implicitly (default: false) - -=== Destination Configuration - -The Kamelet supports both queue and topic destinations. The destination type can be configured using the `destinationType` property, which defaults to `queue`. - -=== AMQP 1.0 Protocol - -This sink uses the AMQP 1.0 protocol over SSL/TLS for sending messages to the broker. AMQP 1.0 is an open standard messaging protocol that provides reliable, secure, and interoperable messaging. diff --git a/docs/modules/ROOT/partials/jms-amqp-10-ssl-source-description.adoc b/docs/modules/ROOT/partials/jms-amqp-10-ssl-source-description.adoc deleted file mode 100644 index 38ec9f80a..000000000 --- a/docs/modules/ROOT/partials/jms-amqp-10-ssl-source-description.adoc +++ /dev/null @@ -1,53 +0,0 @@ -== JMS AMQP 1.0 SSL Source Kamelet Description - -=== Authentication methods - -This Kamelet supports AMQP 1.0 authentication mechanisms over SSL/TLS including: - -- SASL authentication with username and password -- Connection to AMQP 1.0 brokers over SSL/TLS - -=== SSL/TLS Configuration - -SSL transport options are configured as query parameters on the `remoteURI`. Common options include: - -- `transport.trustStoreLocation`: Path to the truststore file -- `transport.trustStorePassword`: Password for the truststore -- `transport.keyStoreLocation`: Path to the keystore file -- `transport.keyStorePassword`: Password for the keystore -- `transport.verifyHost`: Verify hostname matches certificate (default: true) -- `transport.trustAll`: Trust server certificate implicitly (default: false) - -=== Output format - -The Kamelet consumes messages from JMS AMQP 1.0 queues over SSL/TLS and produces the message data in the configured format. - -=== Configuration - -The Kamelet requires connection parameters for the AMQP 1.0 broker: - -- `remoteURI`: The AMQPS broker URI with SSL transport options -- `destinationName`: The destination queue or topic name - -=== Usage example - -```yaml -apiVersion: camel.apache.org/v1alpha1 -kind: KameletBinding -metadata: - name: jms-amqp-10-ssl-source-binding -spec: - source: - ref: - kind: Kamelet - apiVersion: camel.apache.org/v1alpha1 - name: jms-amqp-10-ssl-source - properties: - remoteURI: "amqps://broker.example.com:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" - destinationName: "my-queue" - sink: - ref: - kind: Service - apiVersion: v1 - name: my-service -``` diff --git a/kamelets/jms-amqp-10-sink.kamelet.yaml b/kamelets/jms-amqp-10-sink.kamelet.yaml index bd6825a67..dd570db11 100644 --- a/kamelets/jms-amqp-10-sink.kamelet.yaml +++ b/kamelets/jms-amqp-10-sink.kamelet.yaml @@ -31,7 +31,7 @@ metadata: spec: definition: title: "JMS - AMQP 1.0 Sink" - description: "Send data to any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client." + description: "Send data to any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client. For SSL/TLS connections, use the amqps:// scheme in the remoteURI and configure SSL transport options as query parameters (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." required: - destinationName - remoteURI @@ -48,7 +48,7 @@ spec: type: string remoteURI: title: "Broker URL" - description: "The JMS URL." + description: "The JMS URL. Use the amqps:// scheme for SSL/TLS connections." type: string example: "amqp://my-host:31616" dependencies: diff --git a/kamelets/jms-amqp-10-source.kamelet.yaml b/kamelets/jms-amqp-10-source.kamelet.yaml index 32486d294..ddc43597e 100644 --- a/kamelets/jms-amqp-10-source.kamelet.yaml +++ b/kamelets/jms-amqp-10-source.kamelet.yaml @@ -31,7 +31,7 @@ metadata: spec: definition: title: "JMS - AMQP 1.0 Source" - description: "Consume data from any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client." + description: "Consume data from any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client. For SSL/TLS connections, use the amqps:// scheme in the remoteURI and configure SSL transport options as query parameters (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." required: - destinationName - remoteURI @@ -48,7 +48,7 @@ spec: type: string remoteURI: title: "Broker URL" - description: "The JMS URL." + description: "The JMS URL. Use the amqps:// scheme for SSL/TLS connections." type: string example: "amqp://my-host:31616" dependencies: diff --git a/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml b/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml deleted file mode 100644 index c73d5b96e..000000000 --- a/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml +++ /dev/null @@ -1,70 +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. -# --------------------------------------------------------------------------- -apiVersion: camel.apache.org/v1 -kind: Kamelet -metadata: - name: jms-amqp-10-ssl-sink - annotations: - camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjwhLS0gQ3JlYXRlZCB3aXRoIElua3NjYXBlIChodHRwOi8vd3d3Lmlua3NjYXBlLm9yZy8pIC0tPgoKPHN2ZwogICB4bWxuczpkYz0iaHR0cDovL3B1cmwub3JnL2RjL2VsZW1lbnRzLzEuMS8iCiAgIHhtbG5zOmNjPSJodHRwOi8vY3JlYXRpdmVjb21tb25zLm9yZy9ucyMiCiAgIHhtbG5zOnJkZj0iaHR0cDovL3d3dy53My5vcmcvMTk5OS8wMi8yMi1yZGYtc3ludGF4LW5zIyIKICAgeG1sbnM6c3ZnPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM9Im [...] - camel.apache.org/kamelet.support.level: "Stable" - camel.apache.org/provider: "Apache Software Foundation" - camel.apache.org/catalog.version: "4.21.0-SNAPSHOT" - camel.apache.org/kamelet.group: "JMS" - camel.apache.org/kamelet.namespace: "Messaging" - labels: - camel.apache.org/kamelet.type: "sink" - camel.apache.org/requires.runtime: camel-k -spec: - definition: - title: "JMS - AMQP 1.0 SSL Sink" - description: "Send data to any AMQP 1.0 compliant message broker over an SSL/TLS connection by using the Apache Qpid JMS client. SSL transport options can be configured as query parameters on the remoteURI (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." - required: - - destinationName - - remoteURI - type: object - properties: - destinationType: - title: "Destination Type" - description: "The JMS destination type (queue or topic)." - type: string - default: queue - destinationName: - title: "Destination Name" - description: "The JMS destination name." - type: string - remoteURI: - title: "Broker URL" - description: "The JMS URL with amqps scheme and SSL transport options as query parameters." - type: string - example: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" - dependencies: - - "camel:jms" - - "camel:amqp" - - "camel:kamelet" - template: - beans: - - name: connectionFactoryBean - type: "#class:org.apache.qpid.jms.JmsConnectionFactory" - properties: - remoteURI: '{{remoteURI}}' - from: - uri: "kamelet:source" - steps: - - to: - uri: "jms:{{destinationType}}:{{destinationName}}" - parameters: - connectionFactory: "#bean:{{connectionFactoryBean}}" diff --git a/kamelets/jms-amqp-10-ssl-source.kamelet.yaml b/kamelets/jms-amqp-10-ssl-source.kamelet.yaml deleted file mode 100644 index 403bfb2f0..000000000 --- a/kamelets/jms-amqp-10-ssl-source.kamelet.yaml +++ /dev/null @@ -1,70 +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. -# --------------------------------------------------------------------------- -apiVersion: camel.apache.org/v1 -kind: Kamelet -metadata: - name: jms-amqp-10-ssl-source - annotations: - camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjwhLS0gQ3JlYXRlZCB3aXRoIElua3NjYXBlIChodHRwOi8vd3d3Lmlua3NjYXBlLm9yZy8pIC0tPgoKPHN2ZwogICB4bWxuczpkYz0iaHR0cDovL3B1cmwub3JnL2RjL2VsZW1lbnRzLzEuMS8iCiAgIHhtbG5zOmNjPSJodHRwOi8vY3JlYXRpdmVjb21tb25zLm9yZy9ucyMiCiAgIHhtbG5zOnJkZj0iaHR0cDovL3d3dy53My5vcmcvMTk5OS8wMi8yMi1yZGYtc3ludGF4LW5zIyIKICAgeG1sbnM6c3ZnPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM9Im [...] - camel.apache.org/kamelet.support.level: "Stable" - camel.apache.org/provider: "Apache Software Foundation" - camel.apache.org/catalog.version: "4.21.0-SNAPSHOT" - camel.apache.org/kamelet.group: "JMS" - camel.apache.org/kamelet.namespace: "Messaging" - labels: - camel.apache.org/kamelet.type: "source" - camel.apache.org/requires.runtime: camel-k -spec: - definition: - title: "JMS - AMQP 1.0 SSL Source" - description: "Consume data from any AMQP 1.0 compliant message broker over an SSL/TLS connection by using the Apache Qpid JMS client. SSL transport options can be configured as query parameters on the remoteURI (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." - required: - - destinationName - - remoteURI - type: object - properties: - destinationType: - title: "Destination Type" - description: "The JMS destination type (queue or topic)." - type: string - default: queue - destinationName: - title: "Destination Name" - description: "The JMS destination name." - type: string - remoteURI: - title: "Broker URL" - description: "The JMS URL with amqps scheme and SSL transport options as query parameters." - type: string - example: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" - dependencies: - - "camel:jms" - - "camel:amqp" - - "camel:kamelet" - template: - beans: - - name: connectionFactoryBean - type: "#class:org.apache.qpid.jms.JmsConnectionFactory" - properties: - remoteURI: '{{remoteURI}}' - from: - uri: "jms:{{destinationType}}:{{destinationName}}" - parameters: - connectionFactory: "#bean:{{connectionFactoryBean}}" - steps: - - to: - uri: "kamelet:sink" diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java index 77d7b868f..587e9eb52 100644 --- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java +++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java @@ -78,7 +78,6 @@ public enum KameletPrefixSchemeEnum { jira_transition_issue("jira-transition-issue", "jira"), jira_update_issue("jira-update-issue", "jira"), jms_amqp_10("jms-amqp-10", "jms"), - jms_amqp_10_ssl("jms-amqp-10-ssl", "jms"), jms_apache_artemis("jms-apache-artemis", "jms"), jms_ibm_mq("jms-ibm-mq", "jms"), kafka("kafka", "kafka"), diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java index e30fc69b6..8ab835fcd 100644 --- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java +++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java @@ -209,8 +209,6 @@ public class KameletsCatalogTest { verifyHeaders("jira-oauth-source", 3); verifyHeaders("jms-amqp-10-source", 15); verifyHeaders("jms-amqp-10-sink", 18); - verifyHeaders("jms-amqp-10-ssl-source", 15); - verifyHeaders("jms-amqp-10-ssl-sink", 18); verifyHeaders("jms-apache-artemis-source", 15); verifyHeaders("jms-apache-artemis-sink", 18); verifyHeaders("jms-ibm-mq-source", 15); diff --git a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-sink.kamelet.yaml index bd6825a67..dd570db11 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-sink.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-sink.kamelet.yaml @@ -31,7 +31,7 @@ metadata: spec: definition: title: "JMS - AMQP 1.0 Sink" - description: "Send data to any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client." + description: "Send data to any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client. For SSL/TLS connections, use the amqps:// scheme in the remoteURI and configure SSL transport options as query parameters (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." required: - destinationName - remoteURI @@ -48,7 +48,7 @@ spec: type: string remoteURI: title: "Broker URL" - description: "The JMS URL." + description: "The JMS URL. Use the amqps:// scheme for SSL/TLS connections." type: string example: "amqp://my-host:31616" dependencies: diff --git a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-source.kamelet.yaml index 32486d294..ddc43597e 100644 --- a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-source.kamelet.yaml +++ b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-source.kamelet.yaml @@ -31,7 +31,7 @@ metadata: spec: definition: title: "JMS - AMQP 1.0 Source" - description: "Consume data from any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client." + description: "Consume data from any AMQP 1.0 compliant message broker by using the Apache Qpid JMS client. For SSL/TLS connections, use the amqps:// scheme in the remoteURI and configure SSL transport options as query parameters (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." required: - destinationName - remoteURI @@ -48,7 +48,7 @@ spec: type: string remoteURI: title: "Broker URL" - description: "The JMS URL." + description: "The JMS URL. Use the amqps:// scheme for SSL/TLS connections." type: string example: "amqp://my-host:31616" dependencies: diff --git a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml deleted file mode 100644 index c73d5b96e..000000000 --- a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml +++ /dev/null @@ -1,70 +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. -# --------------------------------------------------------------------------- -apiVersion: camel.apache.org/v1 -kind: Kamelet -metadata: - name: jms-amqp-10-ssl-sink - annotations: - camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjwhLS0gQ3JlYXRlZCB3aXRoIElua3NjYXBlIChodHRwOi8vd3d3Lmlua3NjYXBlLm9yZy8pIC0tPgoKPHN2ZwogICB4bWxuczpkYz0iaHR0cDovL3B1cmwub3JnL2RjL2VsZW1lbnRzLzEuMS8iCiAgIHhtbG5zOmNjPSJodHRwOi8vY3JlYXRpdmVjb21tb25zLm9yZy9ucyMiCiAgIHhtbG5zOnJkZj0iaHR0cDovL3d3dy53My5vcmcvMTk5OS8wMi8yMi1yZGYtc3ludGF4LW5zIyIKICAgeG1sbnM6c3ZnPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM9Im [...] - camel.apache.org/kamelet.support.level: "Stable" - camel.apache.org/provider: "Apache Software Foundation" - camel.apache.org/catalog.version: "4.21.0-SNAPSHOT" - camel.apache.org/kamelet.group: "JMS" - camel.apache.org/kamelet.namespace: "Messaging" - labels: - camel.apache.org/kamelet.type: "sink" - camel.apache.org/requires.runtime: camel-k -spec: - definition: - title: "JMS - AMQP 1.0 SSL Sink" - description: "Send data to any AMQP 1.0 compliant message broker over an SSL/TLS connection by using the Apache Qpid JMS client. SSL transport options can be configured as query parameters on the remoteURI (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." - required: - - destinationName - - remoteURI - type: object - properties: - destinationType: - title: "Destination Type" - description: "The JMS destination type (queue or topic)." - type: string - default: queue - destinationName: - title: "Destination Name" - description: "The JMS destination name." - type: string - remoteURI: - title: "Broker URL" - description: "The JMS URL with amqps scheme and SSL transport options as query parameters." - type: string - example: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" - dependencies: - - "camel:jms" - - "camel:amqp" - - "camel:kamelet" - template: - beans: - - name: connectionFactoryBean - type: "#class:org.apache.qpid.jms.JmsConnectionFactory" - properties: - remoteURI: '{{remoteURI}}' - from: - uri: "kamelet:source" - steps: - - to: - uri: "jms:{{destinationType}}:{{destinationName}}" - parameters: - connectionFactory: "#bean:{{connectionFactoryBean}}" diff --git a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-source.kamelet.yaml deleted file mode 100644 index 403bfb2f0..000000000 --- a/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-source.kamelet.yaml +++ /dev/null @@ -1,70 +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. -# --------------------------------------------------------------------------- -apiVersion: camel.apache.org/v1 -kind: Kamelet -metadata: - name: jms-amqp-10-ssl-source - annotations: - camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PD94bWwgdmVyc2lvbj0iMS4wIiBlbmNvZGluZz0iVVRGLTgiIHN0YW5kYWxvbmU9Im5vIj8+CjwhLS0gQ3JlYXRlZCB3aXRoIElua3NjYXBlIChodHRwOi8vd3d3Lmlua3NjYXBlLm9yZy8pIC0tPgoKPHN2ZwogICB4bWxuczpkYz0iaHR0cDovL3B1cmwub3JnL2RjL2VsZW1lbnRzLzEuMS8iCiAgIHhtbG5zOmNjPSJodHRwOi8vY3JlYXRpdmVjb21tb25zLm9yZy9ucyMiCiAgIHhtbG5zOnJkZj0iaHR0cDovL3d3dy53My5vcmcvMTk5OS8wMi8yMi1yZGYtc3ludGF4LW5zIyIKICAgeG1sbnM6c3ZnPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIKICAgeG1sbnM9Im [...] - camel.apache.org/kamelet.support.level: "Stable" - camel.apache.org/provider: "Apache Software Foundation" - camel.apache.org/catalog.version: "4.21.0-SNAPSHOT" - camel.apache.org/kamelet.group: "JMS" - camel.apache.org/kamelet.namespace: "Messaging" - labels: - camel.apache.org/kamelet.type: "source" - camel.apache.org/requires.runtime: camel-k -spec: - definition: - title: "JMS - AMQP 1.0 SSL Source" - description: "Consume data from any AMQP 1.0 compliant message broker over an SSL/TLS connection by using the Apache Qpid JMS client. SSL transport options can be configured as query parameters on the remoteURI (e.g. transport.trustStoreLocation, transport.trustStorePassword, transport.keyStoreLocation, transport.keyStorePassword, transport.verifyHost, transport.trustAll)." - required: - - destinationName - - remoteURI - type: object - properties: - destinationType: - title: "Destination Type" - description: "The JMS destination type (queue or topic)." - type: string - default: queue - destinationName: - title: "Destination Name" - description: "The JMS destination name." - type: string - remoteURI: - title: "Broker URL" - description: "The JMS URL with amqps scheme and SSL transport options as query parameters." - type: string - example: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" - dependencies: - - "camel:jms" - - "camel:amqp" - - "camel:kamelet" - template: - beans: - - name: connectionFactoryBean - type: "#class:org.apache.qpid.jms.JmsConnectionFactory" - properties: - remoteURI: '{{remoteURI}}' - from: - uri: "jms:{{destinationType}}:{{destinationName}}" - parameters: - connectionFactory: "#bean:{{connectionFactoryBean}}" - steps: - - to: - uri: "kamelet:sink" diff --git a/templates/pipes/camel-k/jms-amqp-10-ssl-sink-pipe.yaml b/templates/pipes/camel-k/jms-amqp-10-ssl-sink-pipe.yaml deleted file mode 100644 index cee3f4106..000000000 --- a/templates/pipes/camel-k/jms-amqp-10-ssl-sink-pipe.yaml +++ /dev/null @@ -1,18 +0,0 @@ -apiVersion: camel.apache.org/v1 -kind: Pipe -metadata: - name: jms-amqp-10-ssl-sink-pipe -spec: - source: - ref: - kind: KafkaTopic - apiVersion: kafka.strimzi.io/v1beta1 - name: my-topic - sink: - ref: - kind: Kamelet - apiVersion: camel.apache.org/v1 - name: jms-amqp-10-ssl-sink - properties: - destinationName: "The Destination Name" - remoteURI: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" diff --git a/templates/pipes/camel-k/jms-amqp-10-ssl-source-pipe.yaml b/templates/pipes/camel-k/jms-amqp-10-ssl-source-pipe.yaml deleted file mode 100644 index eb293e1fa..000000000 --- a/templates/pipes/camel-k/jms-amqp-10-ssl-source-pipe.yaml +++ /dev/null @@ -1,18 +0,0 @@ -apiVersion: camel.apache.org/v1 -kind: Pipe -metadata: - name: jms-amqp-10-ssl-source-pipe -spec: - source: - ref: - kind: Kamelet - apiVersion: camel.apache.org/v1 - name: jms-amqp-10-ssl-source - properties: - destinationName: "The Destination Name" - remoteURI: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" - sink: - ref: - kind: KafkaTopic - apiVersion: kafka.strimzi.io/v1beta1 - name: my-topic diff --git a/templates/pipes/core/jms-amqp-10-ssl-sink-pipe.yaml b/templates/pipes/core/jms-amqp-10-ssl-sink-pipe.yaml deleted file mode 100644 index 630880068..000000000 --- a/templates/pipes/core/jms-amqp-10-ssl-sink-pipe.yaml +++ /dev/null @@ -1,12 +0,0 @@ -- route: - from: - uri: "kamelet:timer-source" - parameters: - period: 1000 - message: "Hello Camel JBang" - steps: - - to: - uri: "kamelet:jms-amqp-10-ssl-sink" - parameters: - destinationName: "The Destination Name" - remoteURI: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" diff --git a/templates/pipes/core/jms-amqp-10-ssl-source-pipe.yaml b/templates/pipes/core/jms-amqp-10-ssl-source-pipe.yaml deleted file mode 100644 index 20a288ecf..000000000 --- a/templates/pipes/core/jms-amqp-10-ssl-source-pipe.yaml +++ /dev/null @@ -1,9 +0,0 @@ -- route: - from: - uri: "kamelet:jms-amqp-10-ssl-source" - parameters: - destinationName: "The Destination Name" - remoteURI: "amqps://my-host:5671?transport.trustStoreLocation=/path/to/truststore.jks&transport.trustStorePassword=changeit" - steps: - - to: - uri: "log:info"
