ActiveMQとQuarkus、Apache Camelで、画像アップロード処理をしたい。 その2 Consumer/Apache Camel編

• Quarkus - Start coding with code.quarkus.redhat.com で、雛形を作ります。
• camel-quarkus-sjms2 / quarkus-artemis-jms を依存関係に含めます。
• ルート用のクラスは、DI対象に含めます。
• ActiveMQ Altemis用の設定を、application.propertiesに記します。

• ActiveMQとQuarkus、ApacheCamelで、画像アップロード処理をしたい。 その1 Producer 編

• Camel Extensions for Quarkus と Camel K の入門 - 赤帽エンジニアブログ
  • はい、この通りに、Maven/Gradeleでプロジェクトを作って、実行してみましょう。¹
  • Quarkus - Start coding with code.quarkus.redhat.com

上記のサンプルだと、少々使いづらい。 Routesクラスを以下のように修正します。

• 継承する親クラスを EndpointRouteBuilder にします。²
  • タイプセーフで、「流れるようなインターフェース」でルートが書けるようになります。
• クラスに @ApplicationScoped アノテーションを付けます。
  • RoutesクラスがDI対象に含まれます。

• camel-quarkus-sjms2を依存関係に加えます。
  • 諸々必要なコンポーネントが自動で入ります。
  • ActiveMQ/JMSを通じて、メッセージを受信するためのコンポーネントには、camel-activemq / camel-jmsがあります。
    • このコンポーネントには、Spring Frameworkのライブラリが依存で入ってしまうのです。
    • ネット上のサンプルプログラムは、Spring-BootベースのConsumerが多いからでしょうね。
• quarkus-artemis-jmsを依存関係に加えます
  • camel-quarkus-sjms2には、ActiveMQとの通信をする、ConnectionFactoryの実装クラスが入ってないのです。
  • Artemis JMSの記述のようにapplication.propertiesに設定を記述すると、ConnectionFactoryもDI対象になります。
  • Quarkus Artemis BOMは、Quarkusと違うので、別途依存関係に追加します。

@ApplicationScoped
public class Routes extends EndpointRouteBuilder {
  private final ConnectionFactory connectionFactory;

  @Override
  public void configure() throws Exception {
    from(sjms2("topic:upload.image").connectionFactory(this.connectionFactory))
        // TODO 何かを処理
        .end();
  }

  @Inject
  public Routes(ConnectionFactory connectionFactory) {
    this.connectionFactory = connectionFactory;
  }
}

Routesクラスは、このような記述になるでしょうか。