39.3. 사용법
이 섹션에서는 jms-ibm-mq-sink 를 사용하는 방법에 대해 설명합니다.
39.3.1. Knative 싱크 링크 복사링크가 클립보드에 복사되었습니다!
jms-ibm-mq-sink Kamelet을 Knative 오브젝트에 바인딩하여 Knative 싱크로 사용할 수 있습니다.
jms-ibm-mq-sink-binding.yaml
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: Channel
apiVersion: messaging.knative.dev/v1
name: mychannel
properties:
serverName: "10.103.41.245"
serverPort: "1414"
destinationType: "queue"
destinationName: "DEV.QUEUE.1"
queueManager: QM1
channel: DEV.APP.SVRCONN
username: app
password: passw0rd
39.3.1.1. 사전 요구 사항 링크 복사링크가 클립보드에 복사되었습니다!
연결된 OpenShift 클러스터에 "Red Hat Integration - Camel K" 가 설치되어 있는지 확인합니다.
39.3.1.2. 클러스터 CLI 사용 절차 링크 복사링크가 클립보드에 복사되었습니다!
-
jms-ibm-mq-sink-binding.yaml파일을 로컬 드라이브에 저장한 다음 구성에 필요한 대로 편집합니다. 다음 명령을 사용하여 싱크를 실행합니다.
oc apply -f jms-ibm-mq-sink-binding.yaml
39.3.1.3. Kamel CLI 사용 절차 링크 복사링크가 클립보드에 복사되었습니다!
다음 명령을 사용하여 싱크를 구성하고 실행합니다.
kamel bind --name jms-ibm-mq-sink-binding timer-source?message="Hello IBM MQ!" 'jms-ibm-mq-sink?serverName=10.103.41.245&serverPort=1414&destinationType=queue&destinationName=DEV.QUEUE.1&queueManager=QM1&channel=DEV.APP.SVRCONN&username=app&password=passw0rd'
이 명령은 클러스터의 현재 네임스페이스에 KameletBinding을 생성합니다.
39.3.2. Kafka Sink 링크 복사링크가 클립보드에 복사되었습니다!
Kafka 항목에 바인딩하여 jms-ibm-mq-sink Kamelet을 Kafka 싱크로 사용할 수 있습니다.
jms-ibm-mq-sink-binding.yaml
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:
serverName: "10.103.41.245"
serverPort: "1414"
destinationType: "queue"
destinationName: "DEV.QUEUE.1"
queueManager: QM1
channel: DEV.APP.SVRCONN
username: app
password: passw0rd
39.3.2.1. 사전 요구 사항 링크 복사링크가 클립보드에 복사되었습니다!
OpenShift 클러스터에 AMQ Streams Operator를 설치하고 현재 네임스페이스에 my-topic 이라는 주제를 생성했는지 확인합니다. 또한 연결된 OpenShift 클러스터에 "Red Hat Integration - Camel K" 가 설치되어 있는지 확인합니다.
39.3.2.2. 클러스터 CLI 사용 절차 링크 복사링크가 클립보드에 복사되었습니다!
-
jms-ibm-mq-sink-binding.yaml파일을 로컬 드라이브에 저장한 다음 구성에 필요한 대로 편집합니다. 다음 명령을 사용하여 싱크를 실행합니다.
oc apply -f jms-ibm-mq-sink-binding.yaml
39.3.2.3. Kamel CLI 사용 절차 링크 복사링크가 클립보드에 복사되었습니다!
다음 명령을 사용하여 싱크를 구성하고 실행합니다.
kamel bind --name jms-ibm-mq-sink-binding timer-source?message="Hello IBM MQ!" 'jms-ibm-mq-sink?serverName=10.103.41.245&serverPort=1414&destinationType=queue&destinationName=DEV.QUEUE.1&queueManager=QM1&channel=DEV.APP.SVRCONN&username=app&password=passw0rd'
이 명령은 클러스터의 현재 네임스페이스에 KameletBinding을 생성합니다.