概要

記事一覧はこちらです。

Spring Boot 1.5.x の Web アプリを 2.0.x へバージョンアップする ( その７ )( src/main/resources/static の下の css や js ファイルにアクセスできない原因とは？ ) の続きです。

今回の手順で確認できるのは以下の内容です。
- ここまでいろいろ変更したので Tomcat を起動して画面から正常に動作するか確認し、動作しない点があれば修正します。

参照したサイト・書籍

correlation id missing when trying to communicate between different rabbitmq rpc library
https://github.com/spring-projects/spring-amqp/issues/657
Spring AMQP - 3.3.3 Stock Trading
https://docs.spring.io/spring-amqp/docs/current/reference/html/reference.html#stock_trading

手順

動作確認１

動作確認前に DB のデータを以下の状態にします。

user_info, user_role テーブルのデータは開発時のままにします。
lending_app, lending_book, library_forsearch テーブルのデータはクリアします。

メールを受信するので smtp4dev を起動します。

f:id:ksby:20181003001818p:plain

Tomcat を起動後、以下の手順で動作確認します。

ブラウザを起動して http://localhost:8080/ にアクセスしてログイン画面を表示します。tanaka.taro@sample.com / taro でログインします。
検索対象図書館登録画面が表示されます。"東京都" で検索した後、一覧表示されている図書館から「国立国会図書館東京本館」を選択します。
ログアウトします。
ログイン画面に戻るので suzuki.hanako@test.co.jp / hanako でログインします。
貸出希望書籍 CSV ファイルアップロード画面が表示されます。以下の内容が記述された CSV ファイルをアップロードします。
"ISBN","書名"
"978-4-7741-6366-6","GitHub実践入門"
"978-4-7741-5377-3","JUnit実践入門"
"978-4-7973-8014-9","Java最強リファレンス"
"978-4-7973-4778-4","アジャイルソフトウェア開発の奥義"
"978-4-87311-704-1","Javaによる関数型プログラミング"

この後メールが送信されてくるはずですが、メールは送信されず NullPointerException が延々と発生していました。

f:id:ksby:20181003004454p:plain

RabbitMQ へのメッセージ送信時に correlationId を付けるよう修正する

NullPointerException が発生している org.springframework.amqp.core.MessageProperties.hashCode(MessageProperties.java:528) をクリックしてみると result = prime * result + this.correlationId.hashCode(); のところでした。Spring Boot 1.5.x の Web アプリを 2.0.x へバージョンアップする ( その４ )( AbstractJsonpResponseBodyAdvice を削除し、失敗しているテストを成功させる ) に書きましたが、2.0 にバージョンアップするとメッセージ送信時に correlationId を必ずセットしないといけなくなっているのですが、セットしていないのが原因のようです。

f:id:ksby:20181003004621p:plain

correlationId は自動で一意の値を割り当ててもらえれば良さそうに思えたので何か方法がないか調べたところ、Spring AMQP - 3.3.3 Stock Trading のページに UUID.randomUUID().toString() を使う方法が記載されていました。今回はこの方法を使うことにします。

メッセージを送信している src/main/java/ksbysamplevwebapp/lending/service/queue/InquiringStatusOfBookQueueService.java の sendMessage メソッドを以下のように変更します。

    public void sendMessage(Long lendingAppId) {
        InquiringStatusOfBookQueueMessage body = new InquiringStatusOfBookQueueMessage();
        body.setLendingAppId(lendingAppId);
        Message message = converter.toMessage(body
                , MessagePropertiesBuilder.newInstance().setCorrelationId(UUID.randomUUID().toString()).build());
        rabbitTemplate.send(Constant.QUEUE_NAME_INQUIRING_STATUSOFBOOK, message);
    }

Message message = converter.toMessage(body, MessagePropertiesBuilder.newInstance().setCorrelationId(UUID.randomUUID().toString()).build()); を追加します。
メッセージ送信時に呼び出すメソッドを rabbitTemplate.convertAndSend → rabbitTemplate.send に変更します。