Provide IBM MQ Sink and Source Kamelets

Fix #901
apache · Apr 29, 2022 · 0a2411a · 0a2411a
1 parent dab356d
commit 0a2411a
Show file tree

Hide file tree

Showing 9 changed files with 580 additions and 0 deletions.
diff --git 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
diff --git a/kamelets/jms-ibm-mq-source.kamelet.yaml b/kamelets/jms-ibm-mq-source.kamelet.yaml
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
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
diff --git a/templates/bindings/camel-k/jms-ibm-mq-sink-binding.yaml 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
@@ -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
@@ -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
@@ -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