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

手順

1. クイックスタートをビルドおよびデプロイするために準備します。

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

      oc login -u developer -p developer

   2. 新しいプロジェクト amq-quickstart を作成します。

      oc new-project amq-quickstart

   3. インストールした AｰMQ 6 イメージおよびテンプレートのバージョンを確認します。

      $ oc get template -n openshift

      amqXX-basic という名前のテンプレートが見つかるはずです。XX は、OpenShift にインストールされた AｰMQ のバージョンになります。

2. A-MQ 6 イメージを amq-quickstart namespace にデプロイします。XX は、前のステップで確認した AｰMQ の実際のバージョンに置き換えます。

   $ oc process openshift//amqXX-basic -p APPLICATION_NAME=broker -p MQ_USERNAME=admin -p MQ_PASSWORD=admin -p MQ_QUEUES=test -p MQ_PROTOCOL=amqp -n amq-quickstart | oc create -f -

   注記

   古いバージョンの oc を使用すると、oc コマンドが失敗することがあります。この構文は、oc のバージョン 3.5.x (Kubernetes 1.5.x がベース) で動作します。

3. メッシュエンドポイントの検出に必要なユーザーロールを追加します (Kubernetes REST API 経由)。

   $ oc policy add-role-to-user view system:serviceaccount:amq-quickstart:default

4. Maven ワークフローを使用して、クイックスタートプロジェクトを作成します。

   $ 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-740017-redhat-00003/archetypes-catalog-2.2.0.fuse-740017-redhat-00003-archetype-catalog.xml \
   -DarchetypeGroupId=org.jboss.fuse.fis.archetypes \
   -DarchetypeArtifactId=spring-boot-camel-amq-archetype \
   -DarchetypeVersion=2.2.0.fuse-740017-redhat-00003

5. archetype プラグインが対話モードに切り替わり、残りのフィールドの入力を要求されます。

   Define value for property 'groupId': : org.example.fis
   Define value for property 'artifactId': : fuse74-spring-boot-camel-amq
   Define value for property 'version':  1.0-SNAPSHOT: :
   Define value for property 'package':  org.example.fis: :
   [INFO] Using property: spring-boot-version = 1.5.17.RELEASE
   Confirm properties configuration:
   groupId: org.example.fis
   artifactId: fuse74-spring-boot-camel-amq
   version: 1.0-SNAPSHOT
   package: org.example.fis
   spring-boot-version: 1.5.17.RELEASE
    Y: :

   プロンプトが表示されたら、groupId の値には org.example.fis、artifactId の値には fuse74-spring-boot-camel-amq を入力します。残りのフィールドにはデフォルト値を使用します。

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

   $ cd fuse74-spring-boot-camel-amq

7. ACTIVEMQ_BROKER_USERNAME および ACTIVEMQ_BROKER_PASSWORD 環境変数を設定して、ブローカーにログインするためのクライアントクレデンシャルをカスタマイズします。fuse74-spring-boot-camel-amq プロジェクトで、以下のように src/main/fabric8/deployment.yml ファイルを編集します。

   spec:
     template:
       spec:
         containers:
           -
             resources:
               requests:
                 cpu: "0.2"
   #              memory: 256Mi
               limits:
                 cpu: "1.0"
   #              memory: 256Mi
             env:
             - name: AMQP_HOST
               value: broker-amq-amqp
             - name: SPRING_APPLICATION_JSON
               value: '{"server":{"undertow":{"io-threads":1, "worker-threads":2 }}}'
             - name: AMQP_USERNAME
               value: admin
             - name: AMQP_PASSWORD
               value: admin

8. mvn コマンドを実行し、クイックスタートを OpenShift サーバーにデプロイします。

   mvn fabric8:deploy -Popenshift

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

   1. OpenShift コンソールに移動します。
   2. プロジェクト amq-quickstart を選択します。
   3. Applications をクリックします。
   4. Pods を選択します。
   5. fis-spring-boot-camel-am-1-xxxxx をクリックします。

   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

10. Web インターフェースでルートを表示するには、Open Java Console をクリックし、A-MQ キューのメッセージをチェックします。