This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch ci-issue-1774 in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 0e31cc0090067d8b7a0c1b6a830938d4154f99ad Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Apr 8 12:23:30 2026 +0200 Fix #1774: Add AMQPS (SSL/TLS) source and sink kamelets Co-Authored-By: Claude Opus 4.6 (1M context) <[email protected]> --- .../partials/jms-amqp-10-ssl-sink-description.adoc | 24 ++++++++ .../jms-amqp-10-ssl-source-description.adoc | 53 ++++++++++++++++ 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-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 +++ 12 files changed, 417 insertions(+) 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 new file mode 100644 index 000000000..fa6e3a673 --- /dev/null +++ b/docs/modules/ROOT/partials/jms-amqp-10-ssl-sink-description.adoc @@ -0,0 +1,24 @@ +== 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 new file mode 100644 index 000000000..38ec9f80a --- /dev/null +++ b/docs/modules/ROOT/partials/jms-amqp-10-ssl-source-description.adoc @@ -0,0 +1,53 @@ +== 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-ssl-sink.kamelet.yaml b/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml new file mode 100644 index 000000000..c8db5884d --- /dev/null +++ b/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml @@ -0,0 +1,70 @@ +# --------------------------------------------------------------------------- +# 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.19.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 new file mode 100644 index 000000000..bebc4c8ba --- /dev/null +++ b/kamelets/jms-amqp-10-ssl-source.kamelet.yaml @@ -0,0 +1,70 @@ +# --------------------------------------------------------------------------- +# 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.19.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 587e9eb52..77d7b868f 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,6 +78,7 @@ 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 bb98384ca..b99a1239f 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,6 +209,8 @@ 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-ssl-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml new file mode 100644 index 000000000..c8db5884d --- /dev/null +++ b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-sink.kamelet.yaml @@ -0,0 +1,70 @@ +# --------------------------------------------------------------------------- +# 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.19.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 new file mode 100644 index 000000000..bebc4c8ba --- /dev/null +++ b/library/camel-kamelets/src/main/resources/kamelets/jms-amqp-10-ssl-source.kamelet.yaml @@ -0,0 +1,70 @@ +# --------------------------------------------------------------------------- +# 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.19.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 new file mode 100644 index 000000000..cee3f4106 --- /dev/null +++ b/templates/pipes/camel-k/jms-amqp-10-ssl-sink-pipe.yaml @@ -0,0 +1,18 @@ +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 new file mode 100644 index 000000000..eb293e1fa --- /dev/null +++ b/templates/pipes/camel-k/jms-amqp-10-ssl-source-pipe.yaml @@ -0,0 +1,18 @@ +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 new file mode 100644 index 000000000..630880068 --- /dev/null +++ b/templates/pipes/core/jms-amqp-10-ssl-sink-pipe.yaml @@ -0,0 +1,12 @@ +- 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 new file mode 100644 index 000000000..20a288ecf --- /dev/null +++ b/templates/pipes/core/jms-amqp-10-ssl-source-pipe.yaml @@ -0,0 +1,9 @@ +- 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"
