You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pc...@apache.org on 2022/05/03 12:52:16 UTC
[camel-k] branch main updated: Provide example for IBM MQ Server
This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k.git
The following commit(s) were added to refs/heads/main by this push:
new 3b69b09a6 Provide example for IBM MQ Server
3b69b09a6 is described below
commit 3b69b09a6d5309d4516410006736932f9a1596b2
Author: Claudio Miranda <cl...@claudius.com.br>
AuthorDate: Mon May 2 11:38:23 2022 -0300
Provide example for IBM MQ Server
Fix https://github.com/apache/camel-k/issues/3247
---
examples/ibm-mq/MQRoute.java | 66 ++++++++++++++++++
examples/ibm-mq/README.md | 42 ++++++++++++
examples/ibm-mq/ibm-mq-server-deploy/README.md | 26 +++++++
.../ibm-mq/ibm-mq-server-deploy/ibm-mq-server.yaml | 79 ++++++++++++++++++++++
examples/ibm-mq/jms-ibm-mq-sink-binding.yaml | 18 +++++
examples/ibm-mq/jms-ibm-mq-source-binding.yaml | 15 ++++
6 files changed, 246 insertions(+)
diff --git a/examples/ibm-mq/MQRoute.java b/examples/ibm-mq/MQRoute.java
new file mode 100644
index 000000000..8ed1b3816
--- /dev/null
+++ b/examples/ibm-mq/MQRoute.java
@@ -0,0 +1,66 @@
+// camel-k: language=java
+/*
+ * 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.
+ */
+
+import com.ibm.mq.jms.MQQueueConnectionFactory;
+import com.ibm.msg.client.wmq.WMQConstants;
+import org.apache.camel.CamelContext;
+import org.apache.camel.ProducerTemplate;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.jms.JmsComponent;
+import org.apache.camel.impl.DefaultCamelContext;
+
+public class MQRoute extends RouteBuilder {
+
+ static String mqHost = "10.108.69.161";
+ static int mqPort = 1414;
+ static String mqQueueManager = "QM1";
+ static String mqChannel = "DEV.APP.SVRCONN";
+ static String mqQueue = "DEV.QUEUE.1";
+ static String user = "app";
+ static String password = "ibmmqpasswd";
+
+ @Override
+ public void configure() {
+ MQQueueConnectionFactory mqFactory = createWMQConnectionFactory(mqHost);
+ getContext().getRegistry().bind("mqConnectionFactory", mqFactory);
+
+ from("timer:tick")
+ .setBody()
+ .simple("Hello Camel K! #${exchangeProperty.CamelTimerCounter}")
+ .to("jms:queue:" + mqQueue + "?connectionFactory=#mqConnectionFactory");
+
+ from("jms:queue:" + mqQueue + "?connectionFactory=#mqConnectionFactory")
+ .to("log:info");
+ }
+
+ private MQQueueConnectionFactory createWMQConnectionFactory(String mqHost) {
+ MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
+ try {
+ mqQueueConnectionFactory.setHostName(mqHost);
+ mqQueueConnectionFactory.setChannel(mqChannel);
+ mqQueueConnectionFactory.setPort(mqPort);
+ mqQueueConnectionFactory.setQueueManager(mqQueueManager);
+ mqQueueConnectionFactory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
+ mqQueueConnectionFactory.setStringProperty(WMQConstants.USERID, user);
+ mqQueueConnectionFactory.setStringProperty(WMQConstants.PASSWORD, password);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return mqQueueConnectionFactory;
+ }
+}
diff --git a/examples/ibm-mq/README.md b/examples/ibm-mq/README.md
new file mode 100644
index 000000000..08bd4a525
--- /dev/null
+++ b/examples/ibm-mq/README.md
@@ -0,0 +1,42 @@
+# Examples showing how to use Camel K to connect to an IBM MQ Server
+
+* Deploy the IBM MQ Server, as describe in the ibm-mq-server-deploy/README.md
+
+* Change the IBM MQ Server address in the MQRoute.java class file
+
+```
+ibmip=`kubectl get svc/ibm-mq-server -ojsonpath="{.spec.clusterIP}"`; sed -i "/mqHost/s/\".*\"/\"$ibmip\"/g" MQRoute.java
+```
+
+For licensing reasons, the IBM MQ Java libraries are not defined in the routes themselves, but you can declare the dependency while running the integration. Alternatively you can use Kamel modeline to add the dependency in the route file as a header.
+
+* Run the MQRoute.java. It is a producer and consumer of messages.
+
+```
+kamel run --dev MQRoute.java -d mvn:com.ibm.mq:com.ibm.mq.allclient:9.2.5.0
+```
+
+It will print the following output in the console
+
+```
+JmsConsumer[DEV.QUEUE.1]) Exchange[ExchangePattern: InOnly, BodyType: String, Body: Hello Camel K! #2]
+```
+
+* If you want to have a more streamlined declarative approach to run the integration using Kamelets, you can use the routes in YAML format.
+
+
+The following kamel commands, has three distincts configurations:
+1. Declare de dependency of IBM MQ Java library as previously mentioned.
+2. Use the IBM MQ Server password set in a kubernetes `Secret` object.
+3. Set the IBM MQ Server IP address as a property to run the integration, so the IBM MQ Cient can connect to the server.
+
+
+Run the integration to generate messages and send them to the IBM MQ Queue (there is no output in the console)
+```
+kamel run --dev jms-ibm-mq-sink-binding.yaml -d mvn:com.ibm.mq:com.ibm.mq.allclient:9.2.5.0 --config secret:ibm-mq/ibm-mq-password -p serverName=`kubectl get svc/ibm-mq-server -ojsonpath="{.spec.clusterIP}"`
+```
+
+Run the integration to retrieve messages from the IBM MQ Queue and print in the console.
+```
+kamel run --dev jms-ibm-mq-source-binding.yaml -d mvn:com.ibm.mq:com.ibm.mq.allclient:9.2.5.0 --config secret:ibm-mq/ibm-mq-password -p serverName=`kubectl get svc/ibm-mq-server -ojsonpath="{.spec.clusterIP}"`
+```
diff --git a/examples/ibm-mq/ibm-mq-server-deploy/README.md b/examples/ibm-mq/ibm-mq-server-deploy/README.md
new file mode 100644
index 000000000..4a0449ea8
--- /dev/null
+++ b/examples/ibm-mq/ibm-mq-server-deploy/README.md
@@ -0,0 +1,26 @@
+# How to deploy a IBM MQ Server to Kubernetes cluster
+
+This is a very simple example to show how to install an IBM MQ Server. **Note**, this is not ready for any production purpose.
+
+The Deployment uses IBM MQ Server image from docker hub.
+
+## Install the IBM MQ Server
+```
+kubectl create -f ibm-mq-server.yaml
+```
+
+This will create a server with the following data:
+
+```
+App User : app
+App Password : ibmmqpasswd
+Queue manager: QM1
+Queue : DEV.QUEUE.1
+Channel : DEV.APP.SVRCONN
+```
+
+## Remove the IBM MQ Server resources
+
+```
+kubectl delete -f ibm-mq-server.yaml
+```
diff --git a/examples/ibm-mq/ibm-mq-server-deploy/ibm-mq-server.yaml b/examples/ibm-mq/ibm-mq-server-deploy/ibm-mq-server.yaml
new file mode 100644
index 000000000..55428ba8c
--- /dev/null
+++ b/examples/ibm-mq/ibm-mq-server-deploy/ibm-mq-server.yaml
@@ -0,0 +1,79 @@
+# ---------------------------------------------------------------------------
+# 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: v1
+kind: Secret
+metadata:
+ name: ibm-mq
+type: Opaque
+# password: ibmmqpasswd
+data:
+ ibm-mq-password: aWJtbXFwYXNzd2Q=
+---
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+ name: ibm-mq-server
+ labels:
+ app: ibm-mq-server
+spec:
+ replicas: 1
+ selector:
+ matchLabels:
+ app: ibm-mq-server
+ template:
+ metadata:
+ labels:
+ app: ibm-mq-server
+ spec:
+ containers:
+ - name: ibm-mq-server
+ image: ibmcom/mq
+ imagePullPolicy: "IfNotPresent"
+ ports:
+ - containerPort: 1414
+ - containerPort: 9443
+ env:
+ - name: LICENSE
+ value: "accept"
+ - name: MQ_QMGR_NAME
+ value: "QM1"
+ - name: MQ_APP_PASSWORD
+ valueFrom:
+ secretKeyRef:
+ name: ibm-mq
+ key: ibm-mq-password
+
+---
+apiVersion: v1
+kind: Service
+metadata:
+ labels:
+ app: ibm-mq-server
+ name: ibm-mq-server
+spec:
+ ports:
+ - name: port-1
+ port: 1414
+ protocol: TCP
+ targetPort: 1414
+ - name: port-2
+ port: 9443
+ protocol: TCP
+ targetPort: 9443
+ selector:
+ app: ibm-mq-server
+ type: ClusterIP
diff --git a/examples/ibm-mq/jms-ibm-mq-sink-binding.yaml b/examples/ibm-mq/jms-ibm-mq-sink-binding.yaml
new file mode 100644
index 000000000..cc0677b56
--- /dev/null
+++ b/examples/ibm-mq/jms-ibm-mq-sink-binding.yaml
@@ -0,0 +1,18 @@
+- route:
+ from:
+ uri: "kamelet:timer-source"
+ parameters:
+ period: 1000
+ message: "Hello Camel K to IBM MQ"
+ steps:
+ - to:
+ uri: "kamelet:jms-ibm-mq-sink"
+ parameters:
+ serverName: "{{serverName}}"
+ serverPort: "1414"
+ destinationType: "queue"
+ destinationName: "DEV.QUEUE.1"
+ queueManager: QM1
+ channel: DEV.APP.SVRCONN
+ username: app
+ password: "{{ibm-mq-password}}"
diff --git a/examples/ibm-mq/jms-ibm-mq-source-binding.yaml b/examples/ibm-mq/jms-ibm-mq-source-binding.yaml
new file mode 100644
index 000000000..528de5623
--- /dev/null
+++ b/examples/ibm-mq/jms-ibm-mq-source-binding.yaml
@@ -0,0 +1,15 @@
+- route:
+ from:
+ uri: "kamelet:jms-ibm-mq-source"
+ parameters:
+ serverName: "{{serverName}}"
+ serverPort: "1414"
+ destinationType: "queue"
+ destinationName: "DEV.QUEUE.1"
+ queueManager: QM1
+ channel: DEV.APP.SVRCONN
+ username: app
+ password: "{{ibm-mq-password}}"
+ steps:
+ - to:
+ uri: kamelet:log-sink