This is an automated email from the ASF dual-hosted git repository.
oscerd pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push:
new a31399c24 Fix #2828: Consolidate JMS AMQP 10 SSL variants into single
kamelets (#2831)
a31399c24 is described below
commit a31399c2483cdfb51103123979ab31e42d5195f4
Author: Andrea Cosentino <[email protected]>
AuthorDate: Wed May 13 12:27:27 2026 +0200
Fix #2828: Consolidate JMS AMQP 10 SSL variants into single kamelets (#2831)
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.
Signed-off-by: Andrea Cosentino <[email protected]>
Co-authored-by: Claude Opus 4.6 (1M context) <[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"
