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 555bbab7 Fix IBM MQ kamelets to use general MQConnectionFactory
555bbab7 is described below
commit 555bbab7ba70f34a11d9a59338bbb7887912d354
Author: Claudio Miranda <[email protected]>
AuthorDate: Tue May 10 19:30:14 2022 -0300
Fix IBM MQ kamelets to use general MQConnectionFactory
* Currently it uses MQQueueConnectionFactory, which is specific for Queues.
It should use MQConnectionFactory, which can be used for queues and topics.
* Add a default property `serverPort: 1414`
* Fix the [yaml dsl routes used in camel
3.15](https://camel.apache.org/manual/camel-3x-upgrade-guide-3_15.html#_camel_yaml_dsl)
Fix https://github.com/apache/camel-kamelets/issues/921
---
kamelets/jms-ibm-mq-sink.kamelet.yaml | 4 ++--
kamelets/jms-ibm-mq-source.kamelet.yaml | 4 ++--
.../kamelets/jms-ibm-mq-sink.kamelet.yaml | 4 ++--
.../kamelets/jms-ibm-mq-source.kamelet.yaml | 4 ++--
.../bindings/core/jms-ibm-mq-sink-binding.yaml | 24 +++++++++++-----------
.../bindings/core/jms-ibm-mq-source-binding.yaml | 8 ++++----
6 files changed, 24 insertions(+), 24 deletions(-)
diff --git a/kamelets/jms-ibm-mq-sink.kamelet.yaml
b/kamelets/jms-ibm-mq-sink.kamelet.yaml
index a3f96c3d..1d899d08 100644
--- a/kamelets/jms-ibm-mq-sink.kamelet.yaml
+++ b/kamelets/jms-ibm-mq-sink.kamelet.yaml
@@ -55,7 +55,7 @@ spec:
title: "IBM MQ Server Port"
description: "IBM MQ Server port"
type: integer
- example: 1414
+ default: 1414
destinationType:
title: "Destination Type"
description: "The JMS destination type (queue or topic)"
@@ -95,7 +95,7 @@ spec:
template:
beans:
- name: wmqConnectionFactory
- type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ type: "#class:com.ibm.mq.jms.MQConnectionFactory"
property:
- key: XMSC_WMQ_HOST_NAME
value: '{{serverName}}'
diff --git a/kamelets/jms-ibm-mq-source.kamelet.yaml
b/kamelets/jms-ibm-mq-source.kamelet.yaml
index 09ef945b..7de7cba4 100644
--- a/kamelets/jms-ibm-mq-source.kamelet.yaml
+++ b/kamelets/jms-ibm-mq-source.kamelet.yaml
@@ -55,7 +55,7 @@ spec:
title: "IBM MQ Server Port"
description: "IBM MQ Server port"
type: integer
- example: 1414
+ default: 1414
destinationType:
title: "Destination Type"
description: "The JMS destination type (queue or topic)"
@@ -95,7 +95,7 @@ spec:
template:
beans:
- name: wmqConnectionFactory
- type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ type: "#class:com.ibm.mq.jms.MQConnectionFactory"
property:
- key: XMSC_WMQ_HOST_NAME
value: '{{serverName}}'
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
index a3f96c3d..1d899d08 100644
---
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
@@ -55,7 +55,7 @@ spec:
title: "IBM MQ Server Port"
description: "IBM MQ Server port"
type: integer
- example: 1414
+ default: 1414
destinationType:
title: "Destination Type"
description: "The JMS destination type (queue or topic)"
@@ -95,7 +95,7 @@ spec:
template:
beans:
- name: wmqConnectionFactory
- type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ type: "#class:com.ibm.mq.jms.MQConnectionFactory"
property:
- key: XMSC_WMQ_HOST_NAME
value: '{{serverName}}'
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
index 09ef945b..7de7cba4 100644
---
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
@@ -55,7 +55,7 @@ spec:
title: "IBM MQ Server Port"
description: "IBM MQ Server port"
type: integer
- example: 1414
+ default: 1414
destinationType:
title: "Destination Type"
description: "The JMS destination type (queue or topic)"
@@ -95,7 +95,7 @@ spec:
template:
beans:
- name: wmqConnectionFactory
- type: "#class:com.ibm.mq.jms.MQQueueConnectionFactory"
+ type: "#class:com.ibm.mq.jms.MQConnectionFactory"
property:
- key: XMSC_WMQ_HOST_NAME
value: '{{serverName}}'
diff --git a/templates/bindings/core/jms-ibm-mq-sink-binding.yaml
b/templates/bindings/core/jms-ibm-mq-sink-binding.yaml
index e28e742c..bb60585e 100644
--- a/templates/bindings/core/jms-ibm-mq-sink-binding.yaml
+++ b/templates/bindings/core/jms-ibm-mq-sink-binding.yaml
@@ -4,15 +4,15 @@
parameters:
period: 1000
message: "Hello Camel to IBM MQ"
- steps:
- - to:
- uri: "kamelet:jms-ibm-mq-sink"
- parameters:
- serverName: "10.103.41.245"
- serverPort: "1414"
- destinationType: "queue"
- destinationName: "DEV.QUEUE.1"
- queueManager: QM1
- channel: DEV.APP.SVRCONN
- username: app
- password: passw0rd
+ steps:
+ - to:
+ uri: "kamelet:jms-ibm-mq-sink"
+ parameters:
+ serverName: "10.105.157.79"
+ serverPort: "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
index 67fbb6bd..000d7f10 100644
--- a/templates/bindings/core/jms-ibm-mq-source-binding.yaml
+++ b/templates/bindings/core/jms-ibm-mq-source-binding.yaml
@@ -2,7 +2,7 @@
from:
uri: "kamelet:jms-ibm-mq-source"
parameters:
- serverName: "10.103.41.245"
+ serverName: "10.105.157.79"
serverPort: "1414"
destinationType: "queue"
destinationName: "DEV.QUEUE.1"
@@ -10,6 +10,6 @@
channel: DEV.APP.SVRCONN
username: app
password: passw0rd
- steps:
- - to:
- uri: kamelet:log-sink
+ steps:
+ - to:
+ uri: kamelet:log-sink
