第10章 Camel アプリケーションの A-MQ ブローカーとの統合

手順

1. 開発者として OpenShift サーバーにログインします。

   oc login -u developer -p developer

   Copy to Clipboard Toggle word wrap

2. 以下のように、クイックスタートの新規プロジェクトを作成します。

   oc new-project quickstart

   Copy to Clipboard Toggle word wrap

3. Maven archetype を使用してクイックスタートプロジェクトを取得します。

   mvn org.apache.maven.plugins:maven-archetype-plugin:2.4:generate -DarchetypeCatalog=https://maven.repository.redhat.com/ga/io/fabric8/archetypes/archetypes-catalog/2.2.0.fuse-sb2-790047-redhat-00004/archetypes-catalog-2.2.0.fuse-sb2-790047-redhat-00004-archetype-catalog.xml -DarchetypeGroupId=org.jboss.fuse.fis.archetypes -DarchetypeArtifactId=spring-boot-camel-amq-archetype -DarchetypeVersion=2.2.0.fuse-sb2-790047-redhat-00004

   Copy to Clipboard Toggle word wrap

4. クイックスタートディレクトリー fuse710-spring-boot-camel-amq に移動します。

   cd fuse710-spring-boot-camel-amq

   Copy to Clipboard Toggle word wrap

5. 以下のコマンドを実行し、設定ファイルを AMQ Broker に適用します。これらの設定ファイルによって、管理者権限を持つ AMQ Broker ユーザーおよびキューが作成されます。

   oc login -u admin -p admin
   
   oc apply -f src/main/resources/k8s

   Copy to Clipboard Toggle word wrap

6. 以下のように、アプリケーションの ConfigMap を作成します。

   kind: ConfigMap
   apiVersion: v1
   metadata:
     name: spring-boot-camel-amq-config
     namespace: quickstarts
   data:
     service.host: 'fuse-broker-amqps-0-svc'
     service.port.amqp: '5672'
     service.port.amqps: '5671'

   Copy to Clipboard Toggle word wrap

7. ステップ 3 の ImageStream を使用して、mvn コマンドを実行してクイックスタートを OpenShift サーバーにデプロイします。

   mvn oc:deploy -Popenshift -Djkube.generator.fromMode=istag -Djkube.generator.from=openshift/fuse-java-openshift:1.9

   Copy to Clipboard Toggle word wrap

8. クイックスタートが正常に実行されていることを確認するには、以下を行います。

   1. ブラウザーで https://OPENSHIFT_IP_ADDR の OpenShift Web コンソールに移動します。OPENSHIFT_IP_ADDR はクラスターの IP アドレスに置き換えます。クレデンシャル (例: ユーザー名 developer、パスワード developer) を使用して、コンソールにログインします。
   2. 左側のパネルで Home をデプロイメントし、Status をクリックして openshift プロジェクトの Project Status ページを表示します。
   3. fuse710-spring-boot-camel-amq をクリックし、クイックスタートの概要情報ページを表示します。
   4. 左側のパネルで Workloads を展開します。
   5. Pods をクリックした後、fuse710-spring-boot-camel-amq-xxxxx をクリックします。クイックスタートの Pod の詳細が表示されます。

   6. Logs をクリックし、アプリケーションのログを確認します。

      出力にはメッセージが正常に送信されたことが表示されます。

      10:17:59.825 [Camel (camel) thread #10 - timer://order] INFO  generate-order-route - Generating order order1379.xml
      10:17:59.829 [Camel (camel) thread #8 - JmsConsumer[incomingOrders]] INFO  jms-cbr-route - Sending order order1379.xml to the UK
      10:17:59.829 [Camel (camel) thread #8 - JmsConsumer[incomingOrders]] INFO  jms-cbr-route - Done processing order1379.xml
      10:18:02.825 [Camel (camel) thread #10 - timer://order] INFO  generate-order-route - Generating order order1380.xml
      10:18:02.829 [Camel (camel) thread #7 - JmsConsumer[incomingOrders]] INFO  jms-cbr-route - Sending order order1380.xml to another country
      10:18:02.829 [Camel (camel) thread #7 - JmsConsumer[incomingOrders]] INFO jms-cbr-route - Done processing order1380.xml

      Copy to Clipboard Toggle word wrap
9. Web インターフェイスでルートを表示するには、Open Java Console をクリックし、AMQ キューのメッセージをチェックします。