You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/04/29 12:20:28 UTC
[camel-kamelets] branch main updated: Provide IBM MQ Sink and Source Kamelets
This is an automated email from the ASF dual-hosted git repository.
acosentino 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 d1e851bd Provide IBM MQ Sink and Source Kamelets
d1e851bd is described below
commit d1e851bd74e0d3f4556c907ad050ecdde2e68e85
Author: Claudio Miranda <cl...@claudius.com.br>
AuthorDate: Fri Apr 29 00:50:57 2022 -0300
Provide IBM MQ Sink and Source Kamelets
Fix https://github.com/apache/camel-kamelets/issues/901
---
docs/modules/ROOT/nav.adoc | 2 +
kamelets/jms-ibm-mq-sink.kamelet.yaml | 122 +++++++++++++++++++++
kamelets/jms-ibm-mq-source.kamelet.yaml | 122 +++++++++++++++++++++
.../kamelets/jms-ibm-mq-sink.kamelet.yaml | 122 +++++++++++++++++++++
.../kamelets/jms-ibm-mq-source.kamelet.yaml | 122 +++++++++++++++++++++
.../bindings/camel-k/jms-ibm-mq-sink-binding.yaml | 25 +++++
.../camel-k/jms-ibm-mq-source-binding.yaml | 26 +++++
.../bindings/core/jms-ibm-mq-sink-binding.yaml | 18 +++
.../bindings/core/jms-ibm-mq-source-binding.yaml | 15 +++
9 files changed, 574 insertions(+)
diff --git a/docs/modules/ROOT/nav.adoc b/docs/modules/ROOT/nav.adoc
index fed37847..5aad588f 100644
--- a/docs/modules/ROOT/nav.adoc
+++ b/docs/modules/ROOT/nav.adoc
@@ -94,6 +94,8 @@
* xref:jms-apache-activemq-source.adoc[]
* xref:jms-apache-artemis-sink.adoc[]
* xref:jms-apache-artemis-source.adoc[]
+* xref:jms-ibm-mq-sink.adoc[]
+* xref:jms-ibm-mq-source.adoc[]
* xref:jolt-transformation-action.adoc[]
* xref:jslt-action.adoc[]
* xref:json-deserialize-action.adoc[]
diff --git a/kamelets/jms-ibm-mq-sink.kamelet.yaml b/kamelets/jms-ibm-mq-sink.kamelet.yaml
new file mode 100644
index 00000000..a3f96c3d
--- /dev/null
+++ b/kamelets/jms-ibm-mq-sink.kamelet.yaml
@@ -0,0 +1,122 @@
+# ---------------------------------------------------------------------------
+# 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/v1alpha1
+kind: Kamelet
+metadata:
+ name: jms-ibm-mq-sink
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyBpZD0iTGF5ZXJfMSIgZGF0YS1uYW1lPSJMYXllciAxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgNTczLjA4IDU3Ni45NyI+PGRlZnM+PHN0eWxlPi5jbHMtMXtmaWxsOiNmZmY7fS5jbHMtMntmaWxsOiM1YTc3YjU7fS5jbHMtM3tmaWxsOiNhZmJlZTA7fS5jbHMtNHtjbGlwLXBhdGg6dXJsKCNjbGlwLXBhdGgpO30uY2xzLTV7Y2xpcC1wYXRoOnVybCgjY2xpcC1wYXRoLTIpO308L3N0eWxlPjxjbGlwUGF0aCBpZD0iY2xpcC1wYXRoIj48cG [...]
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/catalog.version: "main-SNAPSHOT"
+ camel.apache.org/kamelet.group: "JMS"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+ camel.apache.org/requires.runtime: camel-k
+spec:
+ definition:
+ title: "JMS - IBM MQ Kamelet Sink"
+ description: |-
+ A Kamelet that can produce events to an IBM MQ message queue using JMS.
+
+ In your KameletBinding file you'll need to explicitly declare the IBM MQ Server driver dependency in spec->integration->dependencies
+
+ - "mvn:com.ibm.mq:com.ibm.mq.allclient:<version>"
+
+ required:
+ - serverName
+ - serverPort
+ - destinationName
+ - queueManager
+ - channel
+ - username
+ - password
+ type: object
+ properties:
+ serverName:
+ title: "IBM MQ Server name"
+ description: "IBM MQ Server name or address"
+ type: string
+ serverPort:
+ title: "IBM MQ Server Port"
+ description: "IBM MQ Server port"
+ type: integer
+ example: 1414
+ destinationType:
+ title: "Destination Type"
+ description: "The JMS destination type (queue or topic)"
+ type: string
+ default: queue
+ destinationName:
+ title: "Destination Name"
+ description: "The destination name"
+ type: string
+ queueManager:
+ title: "IBM MQ Queue Manager"
+ description: "Name of the IBM MQ Queue Manager"
+ type: string
+ channel:
+ title: "IBM MQ Channel"
+ description: "Name of the IBM MQ Channel"
+ type: string
+ clientId:
+ title: "IBM MQ Client ID"
+ description: "Name of the IBM MQ Client ID"
+ type: string
+ username:
+ title: "Username"
+ description: "Username to authenticate to IBM MQ server"
+ type: string
+ password:
+ title: "Password"
+ description: "Password to authenticate to IBM MQ server"
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ dependencies:
+ - "camel:jms"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: wmqConnectionFactory
+ type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ property:
+ - key: XMSC_WMQ_HOST_NAME
+ value: '{{serverName}}'
+ - key: XMSC_WMQ_PORT
+ value: '{{serverPort}}'
+ - key: XMSC_WMQ_CHANNEL
+ value: '{{channel}}'
+ - key: XMSC_WMQ_QUEUE_MANAGER
+ value: '{{queueManager}}'
+ - key: XMSC_WMQ_CONNECTION_MODE
+ value: 1
+ - key: XMSC_USERID
+ value: '{{username}}'
+ - key: XMSC_PASSWORD
+ value: '{{password}}'
+ - key: XMSC_CLIENT_ID
+ value: '{{?clientId}}'
+ from:
+ uri: "kamelet:source"
+ steps:
+ - to:
+ uri: "jms:{{destinationType}}:{{destinationName}}"
+ parameters:
+ connectionFactory: "#bean:{{wmqConnectionFactory}}"
diff --git a/kamelets/jms-ibm-mq-source.kamelet.yaml b/kamelets/jms-ibm-mq-source.kamelet.yaml
new file mode 100644
index 00000000..09ef945b
--- /dev/null
+++ b/kamelets/jms-ibm-mq-source.kamelet.yaml
@@ -0,0 +1,122 @@
+# ---------------------------------------------------------------------------
+# 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/v1alpha1
+kind: Kamelet
+metadata:
+ name: jms-ibm-mq-source
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyBpZD0iTGF5ZXJfMSIgZGF0YS1uYW1lPSJMYXllciAxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgNTczLjA4IDU3Ni45NyI+PGRlZnM+PHN0eWxlPi5jbHMtMXtmaWxsOiNmZmY7fS5jbHMtMntmaWxsOiM1YTc3YjU7fS5jbHMtM3tmaWxsOiNhZmJlZTA7fS5jbHMtNHtjbGlwLXBhdGg6dXJsKCNjbGlwLXBhdGgpO30uY2xzLTV7Y2xpcC1wYXRoOnVybCgjY2xpcC1wYXRoLTIpO308L3N0eWxlPjxjbGlwUGF0aCBpZD0iY2xpcC1wYXRoIj48cG [...]
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/catalog.version: "main-SNAPSHOT"
+ camel.apache.org/kamelet.group: "JMS"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+ camel.apache.org/requires.runtime: camel-k
+spec:
+ definition:
+ title: "JMS - IBM MQ Kamelet Source"
+ description: |-
+ A Kamelet that can read events from an IBM MQ message queue using JMS.
+
+ In your KameletBinding file you'll need to explicitly declare the IBM MQ Server driver dependency in spec->integration->dependencies
+
+ - "mvn:com.ibm.mq:com.ibm.mq.allclient:<version>"
+
+ required:
+ - serverName
+ - serverPort
+ - destinationName
+ - queueManager
+ - channel
+ - username
+ - password
+ type: object
+ properties:
+ serverName:
+ title: "IBM MQ Server name"
+ description: "IBM MQ Server name or address"
+ type: string
+ serverPort:
+ title: "IBM MQ Server Port"
+ description: "IBM MQ Server port"
+ type: integer
+ example: 1414
+ destinationType:
+ title: "Destination Type"
+ description: "The JMS destination type (queue or topic)"
+ type: string
+ default: queue
+ destinationName:
+ title: "Destination Name"
+ description: "The destination name"
+ type: string
+ queueManager:
+ title: "IBM MQ Queue Manager"
+ description: "Name of the IBM MQ Queue Manager"
+ type: string
+ channel:
+ title: "IBM MQ Channel"
+ description: "Name of the IBM MQ Channel"
+ type: string
+ clientId:
+ title: "IBM MQ Client ID"
+ description: "Name of the IBM MQ Client ID"
+ type: string
+ username:
+ title: "Username"
+ description: "Username to authenticate to IBM MQ server"
+ type: string
+ password:
+ title: "Password"
+ description: "Password to authenticate to IBM MQ server"
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ dependencies:
+ - "camel:jms"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: wmqConnectionFactory
+ type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ property:
+ - key: XMSC_WMQ_HOST_NAME
+ value: '{{serverName}}'
+ - key: XMSC_WMQ_PORT
+ value: '{{serverPort}}'
+ - key: XMSC_WMQ_CHANNEL
+ value: '{{channel}}'
+ - key: XMSC_WMQ_QUEUE_MANAGER
+ value: '{{queueManager}}'
+ - key: XMSC_WMQ_CONNECTION_MODE
+ value: 1
+ - key: XMSC_USERID
+ value: '{{username}}'
+ - key: XMSC_PASSWORD
+ value: '{{password}}'
+ - key: XMSC_CLIENT_ID
+ value: '{{?clientId}}'
+ from:
+ uri: "jms:{{destinationType}}:{{destinationName}}"
+ parameters:
+ connectionFactory: "#bean:{{wmqConnectionFactory}}"
+ steps:
+ - to:
+ uri: "kamelet:sink"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/jms-ibm-mq-sink.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/jms-ibm-mq-sink.kamelet.yaml
new file mode 100644
index 00000000..a3f96c3d
--- /dev/null
+++ b/library/camel-kamelets/src/main/resources/kamelets/jms-ibm-mq-sink.kamelet.yaml
@@ -0,0 +1,122 @@
+# ---------------------------------------------------------------------------
+# 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/v1alpha1
+kind: Kamelet
+metadata:
+ name: jms-ibm-mq-sink
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyBpZD0iTGF5ZXJfMSIgZGF0YS1uYW1lPSJMYXllciAxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgNTczLjA4IDU3Ni45NyI+PGRlZnM+PHN0eWxlPi5jbHMtMXtmaWxsOiNmZmY7fS5jbHMtMntmaWxsOiM1YTc3YjU7fS5jbHMtM3tmaWxsOiNhZmJlZTA7fS5jbHMtNHtjbGlwLXBhdGg6dXJsKCNjbGlwLXBhdGgpO30uY2xzLTV7Y2xpcC1wYXRoOnVybCgjY2xpcC1wYXRoLTIpO308L3N0eWxlPjxjbGlwUGF0aCBpZD0iY2xpcC1wYXRoIj48cG [...]
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/catalog.version: "main-SNAPSHOT"
+ camel.apache.org/kamelet.group: "JMS"
+ labels:
+ camel.apache.org/kamelet.type: "sink"
+ camel.apache.org/requires.runtime: camel-k
+spec:
+ definition:
+ title: "JMS - IBM MQ Kamelet Sink"
+ description: |-
+ A Kamelet that can produce events to an IBM MQ message queue using JMS.
+
+ In your KameletBinding file you'll need to explicitly declare the IBM MQ Server driver dependency in spec->integration->dependencies
+
+ - "mvn:com.ibm.mq:com.ibm.mq.allclient:<version>"
+
+ required:
+ - serverName
+ - serverPort
+ - destinationName
+ - queueManager
+ - channel
+ - username
+ - password
+ type: object
+ properties:
+ serverName:
+ title: "IBM MQ Server name"
+ description: "IBM MQ Server name or address"
+ type: string
+ serverPort:
+ title: "IBM MQ Server Port"
+ description: "IBM MQ Server port"
+ type: integer
+ example: 1414
+ destinationType:
+ title: "Destination Type"
+ description: "The JMS destination type (queue or topic)"
+ type: string
+ default: queue
+ destinationName:
+ title: "Destination Name"
+ description: "The destination name"
+ type: string
+ queueManager:
+ title: "IBM MQ Queue Manager"
+ description: "Name of the IBM MQ Queue Manager"
+ type: string
+ channel:
+ title: "IBM MQ Channel"
+ description: "Name of the IBM MQ Channel"
+ type: string
+ clientId:
+ title: "IBM MQ Client ID"
+ description: "Name of the IBM MQ Client ID"
+ type: string
+ username:
+ title: "Username"
+ description: "Username to authenticate to IBM MQ server"
+ type: string
+ password:
+ title: "Password"
+ description: "Password to authenticate to IBM MQ server"
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ dependencies:
+ - "camel:jms"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: wmqConnectionFactory
+ type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ property:
+ - key: XMSC_WMQ_HOST_NAME
+ value: '{{serverName}}'
+ - key: XMSC_WMQ_PORT
+ value: '{{serverPort}}'
+ - key: XMSC_WMQ_CHANNEL
+ value: '{{channel}}'
+ - key: XMSC_WMQ_QUEUE_MANAGER
+ value: '{{queueManager}}'
+ - key: XMSC_WMQ_CONNECTION_MODE
+ value: 1
+ - key: XMSC_USERID
+ value: '{{username}}'
+ - key: XMSC_PASSWORD
+ value: '{{password}}'
+ - key: XMSC_CLIENT_ID
+ value: '{{?clientId}}'
+ from:
+ uri: "kamelet:source"
+ steps:
+ - to:
+ uri: "jms:{{destinationType}}:{{destinationName}}"
+ parameters:
+ connectionFactory: "#bean:{{wmqConnectionFactory}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/jms-ibm-mq-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/jms-ibm-mq-source.kamelet.yaml
new file mode 100644
index 00000000..09ef945b
--- /dev/null
+++ b/library/camel-kamelets/src/main/resources/kamelets/jms-ibm-mq-source.kamelet.yaml
@@ -0,0 +1,122 @@
+# ---------------------------------------------------------------------------
+# 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/v1alpha1
+kind: Kamelet
+metadata:
+ name: jms-ibm-mq-source
+ annotations:
+ camel.apache.org/kamelet.icon: "data:image/svg+xml;base64,PHN2ZyBpZD0iTGF5ZXJfMSIgZGF0YS1uYW1lPSJMYXllciAxIiB4bWxucz0iaHR0cDovL3d3dy53My5vcmcvMjAwMC9zdmciIHhtbG5zOnhsaW5rPSJodHRwOi8vd3d3LnczLm9yZy8xOTk5L3hsaW5rIiB2aWV3Qm94PSIwIDAgNTczLjA4IDU3Ni45NyI+PGRlZnM+PHN0eWxlPi5jbHMtMXtmaWxsOiNmZmY7fS5jbHMtMntmaWxsOiM1YTc3YjU7fS5jbHMtM3tmaWxsOiNhZmJlZTA7fS5jbHMtNHtjbGlwLXBhdGg6dXJsKCNjbGlwLXBhdGgpO30uY2xzLTV7Y2xpcC1wYXRoOnVybCgjY2xpcC1wYXRoLTIpO308L3N0eWxlPjxjbGlwUGF0aCBpZD0iY2xpcC1wYXRoIj48cG [...]
+ camel.apache.org/kamelet.support.level: "Preview"
+ camel.apache.org/provider: "Apache Software Foundation"
+ camel.apache.org/catalog.version: "main-SNAPSHOT"
+ camel.apache.org/kamelet.group: "JMS"
+ labels:
+ camel.apache.org/kamelet.type: "source"
+ camel.apache.org/requires.runtime: camel-k
+spec:
+ definition:
+ title: "JMS - IBM MQ Kamelet Source"
+ description: |-
+ A Kamelet that can read events from an IBM MQ message queue using JMS.
+
+ In your KameletBinding file you'll need to explicitly declare the IBM MQ Server driver dependency in spec->integration->dependencies
+
+ - "mvn:com.ibm.mq:com.ibm.mq.allclient:<version>"
+
+ required:
+ - serverName
+ - serverPort
+ - destinationName
+ - queueManager
+ - channel
+ - username
+ - password
+ type: object
+ properties:
+ serverName:
+ title: "IBM MQ Server name"
+ description: "IBM MQ Server name or address"
+ type: string
+ serverPort:
+ title: "IBM MQ Server Port"
+ description: "IBM MQ Server port"
+ type: integer
+ example: 1414
+ destinationType:
+ title: "Destination Type"
+ description: "The JMS destination type (queue or topic)"
+ type: string
+ default: queue
+ destinationName:
+ title: "Destination Name"
+ description: "The destination name"
+ type: string
+ queueManager:
+ title: "IBM MQ Queue Manager"
+ description: "Name of the IBM MQ Queue Manager"
+ type: string
+ channel:
+ title: "IBM MQ Channel"
+ description: "Name of the IBM MQ Channel"
+ type: string
+ clientId:
+ title: "IBM MQ Client ID"
+ description: "Name of the IBM MQ Client ID"
+ type: string
+ username:
+ title: "Username"
+ description: "Username to authenticate to IBM MQ server"
+ type: string
+ password:
+ title: "Password"
+ description: "Password to authenticate to IBM MQ server"
+ type: string
+ format: password
+ x-descriptors:
+ - urn:alm:descriptor:com.tectonic.ui:password
+ - urn:camel:group:credentials
+ dependencies:
+ - "camel:jms"
+ - "camel:kamelet"
+ template:
+ beans:
+ - name: wmqConnectionFactory
+ type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ property:
+ - key: XMSC_WMQ_HOST_NAME
+ value: '{{serverName}}'
+ - key: XMSC_WMQ_PORT
+ value: '{{serverPort}}'
+ - key: XMSC_WMQ_CHANNEL
+ value: '{{channel}}'
+ - key: XMSC_WMQ_QUEUE_MANAGER
+ value: '{{queueManager}}'
+ - key: XMSC_WMQ_CONNECTION_MODE
+ value: 1
+ - key: XMSC_USERID
+ value: '{{username}}'
+ - key: XMSC_PASSWORD
+ value: '{{password}}'
+ - key: XMSC_CLIENT_ID
+ value: '{{?clientId}}'
+ from:
+ uri: "jms:{{destinationType}}:{{destinationName}}"
+ parameters:
+ connectionFactory: "#bean:{{wmqConnectionFactory}}"
+ steps:
+ - to:
+ uri: "kamelet:sink"
diff --git a/templates/bindings/camel-k/jms-ibm-mq-sink-binding.yaml b/templates/bindings/camel-k/jms-ibm-mq-sink-binding.yaml
new file mode 100644
index 00000000..b8290cb8
--- /dev/null
+++ b/templates/bindings/camel-k/jms-ibm-mq-sink-binding.yaml
@@ -0,0 +1,25 @@
+# example_for_kamelet_doc
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+ name: jms-ibm-mq-sink-binding
+spec:
+ source:
+ ref:
+ kind: KafkaTopic
+ apiVersion: kafka.strimzi.io/v1beta1
+ name: my-topic
+ sink:
+ ref:
+ kind: Kamelet
+ apiVersion: camel.apache.org/v1alpha1
+ name: jms-ibm-mq-sink
+ properties:
+ host: "10.103.41.245"
+ port: "1414"
+ destinationType: "queue"
+ destinationName: "DEV.QUEUE.1"
+ queueManager: QM1
+ channel: DEV.APP.SVRCONN
+ username: app
+ password: passw0rd
diff --git a/templates/bindings/camel-k/jms-ibm-mq-source-binding.yaml b/templates/bindings/camel-k/jms-ibm-mq-source-binding.yaml
new file mode 100644
index 00000000..c77773a1
--- /dev/null
+++ b/templates/bindings/camel-k/jms-ibm-mq-source-binding.yaml
@@ -0,0 +1,26 @@
+# example_for_kamelet_doc
+apiVersion: camel.apache.org/v1alpha1
+kind: KameletBinding
+metadata:
+ name: jms-ibm-mq-source-binding
+spec:
+ source:
+ ref:
+ kind: Kamelet
+ apiVersion: camel.apache.org/v1alpha1
+ name: jms-ibm-mq-source
+ properties:
+ host: "10.103.41.245"
+ port: "1414"
+ destinationType: "queue"
+ destinationName: "DEV.QUEUE.1"
+ queueManager: QM1
+ channel: DEV.APP.SVRCONN
+ username: app
+ password: passw0rd
+ sink:
+ ref:
+ kind: KafkaTopic
+ apiVersion: kafka.strimzi.io/v1beta1
+ name: my-topic
+
diff --git a/templates/bindings/core/jms-ibm-mq-sink-binding.yaml b/templates/bindings/core/jms-ibm-mq-sink-binding.yaml
new file mode 100644
index 00000000..5d9abb36
--- /dev/null
+++ b/templates/bindings/core/jms-ibm-mq-sink-binding.yaml
@@ -0,0 +1,18 @@
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 1000
+ message: "Hello Camel to IBM MQ"
+ steps:
+ - to:
+ uri: "kamelet:jms-ibm-mq-sink"
+ parameters:
+ host: "10.103.41.245"
+ port: "1414"
+ destinationType: "queue"
+ destinationName: "DEV.QUEUE.1"
+ queueManager: QM1
+ channel: DEV.APP.SVRCONN
+ username: app
+ password: passw0rd
diff --git a/templates/bindings/core/jms-ibm-mq-source-binding.yaml b/templates/bindings/core/jms-ibm-mq-source-binding.yaml
new file mode 100644
index 00000000..5ac69a80
--- /dev/null
+++ b/templates/bindings/core/jms-ibm-mq-source-binding.yaml
@@ -0,0 +1,15 @@
+- route:
+ from:
+ uri: "kamelet:jms-ibm-mq-source"
+ parameters:
+ host: "10.103.41.245"
+ port: "1414"
+ destinationType: "queue"
+ destinationName: "DEV.QUEUE.1"
+ queueManager: QM1
+ channel: DEV.APP.SVRCONN
+ username: app
+ password: passw0rd
+ steps:
+ - to:
+ uri: kamelet:log-sink