Quarkus の Camel エクステンション

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-avro</artifactId>
</dependency>

vanilla Camel から知られている標準的な使用方法以外に、Camel Quarkus では @BuildTimeAvroDataFormat アノテーションを用いて、JVM と Native モードの両方でビルド時に Avro スキーマを解析する機能が追加されています。

以下の例では、最初のステップで user.avsc スキーマリソースがビルド時に解析されます。2 番目のステップで、以前解析されたスキーマを使用する AvroDataFormat インスタンスが、実行時に buildTimeAvroDataFormat フィールドに注入されます。最終的に、受信メッセージをマーシャリングするために、注入されたデータフォーマットを configure() メソッドから使用します。

@BuildTimeAvroDataFormat("user.avsc")
AvroDataFormat buildTimeAvroDataFormat;

@Override
public void configure() {
  from("direct:marshalUsingBuildTimeAvroDataFormat").marshal(buildTimeAvroDataFormat);
}

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-ddb</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-kinesis</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-lambda</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-s3</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-sns</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-aws2-sqs</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-bean</artifactId>
</dependency>

Camel レジストリーで使用できる Bean のメソッドを呼び出す場合を除き、Bean コンポーネントおよび Bean メソッド言語は、Quarkus CDI Bean を呼び出することもできます。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-bindy</artifactId>
</dependency>

ネイティブモードで camel-quarkus-bindy を使用する場合は、ビルドマシンのデフォルトロケールのみがサポートされます。

たとえば、デフォルトロケールが french のビルドマシンの場合、以下のコード

BindyDataFormat dataFormat = new BindyDataFormat();
dataFormat.setLocale("ar");

は、JVM モードでは期待どおりに数値をアラビア数字にフォーマットします。ただし、ネイティブモードでは数値をフランス語的にフォーマットします。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-core</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-direct</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-elasticsearch-rest</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-file</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-ftp</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-hl7</artifactId>
</dependency>

MLLP と TCP を使用する場合には、Netty が Hl7 MLLP リスナーを実行する唯一のサポートされる手段です。現在、GraalVM ネイティブサポートがないため、Mina はサポートされません。

HL7MLLPNettyEncoderFactory および HL7MLLPNettyDecoderFactory コーデックのオプションのサポートは、プロジェクト pom.xml の依存関係を camel-quarkus-netty に追加することで取得できます。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-http</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jackson</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jackson-avro</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jackson-protobuf</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jacksonxml</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jira</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jms</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jsonpath</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-jta</artifactId>
</dependency>

このエクステンションは、ルーターで transacted() EIP を使用する必要がある場合に追加する必要があります。これは、Quarkus の narayana-jta エクステンションによって提供されるトランザクション機能を利用します。

トランザクションサポートの詳細は、「Quarkus Transaction guide」を参照してください。簡単な使用方法の場合:

from("direct:transaction")
    .transacted()
    .to("sql:INSERT INTO A TABLE ...?dataSource=ds1")
    .to("sql:INSERT INTO A TABLE ...?dataSource=ds2")
    .log("all data are in the ds1 and ds2")

さまざまなトランザクションポリシーのサポートが提供されます。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-kafka</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-kamelet</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-log</artifactId>
</dependency>

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-main</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-microprofile-health</artifactId>
</dependency>

デフォルトでは、AbstractHealthCheck を拡張するクラスは liveness および readiness チェックの両方として登録されます。isReadiness メソッドを上書きして、この動作を制御できます。

アプリケーションによって提供されるチェックは自動的に検出され、Camel レジストリーにバインドされます。これらは、Quarkus ヘルスエンドポイント /health/live および /health/ready から利用できます。

カスタムの HealthCheckRepository 実装も提供でき、これらの実装も自動的に検出され、Camel レジストリーにバインドされます。

詳細は、「Quarkus health guide」を参照してください。

ビルド時に修正される設定プロパティー。その他の設定プロパティーはすべて、ランタイム時にオーバーライドが可能です。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-microprofile-metrics</artifactId>
</dependency>

microprofile-metrics コンポーネントは Camel アプリケーションメトリクスのセットを自動的に公開します。これには以下が含まれます。

ビルド時に修正される設定プロパティー。その他の設定プロパティーはすべて、ランタイム時にオーバーライドが可能です。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-mllp</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-mock</artifactId>
</dependency>

テストで camel-mock 機能を使用するには、MockEndpoint インスタンスへのアクセスを取得する必要があります。

CDI の注入は、インスタンスへのアクセスに使用できます (Quarkus ドキュメント を参照してください)。@Inject アノテーションを使用して camelContext をテストに注入できます。その後、Camel コンテキストを使用してモックエンドポイントを取得できます。以下の例を参照してください。

import javax.inject.Inject;

import org.apache.camel.CamelContext;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.component.mock.MockEndpoint;
import org.junit.jupiter.api.Test;

import io.quarkus.test.junit.QuarkusTest;

@QuarkusTest
public class MockJvmTest {

    @Inject
    CamelContext camelContext;

    @Inject
    ProducerTemplate producerTemplate;

    @Test
    public void test() throws InterruptedException {

        producerTemplate.sendBody("direct:start", "Hello World");

        MockEndpoint mockEndpoint = camelContext.getEndpoint("mock:result", MockEndpoint.class);
        mockEndpoint.expectedBodiesReceived("Hello World");

        mockEndpoint.assertIsSatisfied();
    }
}

サンプルテストに使用するルート:

import javax.enterprise.context.ApplicationScoped;

import org.apache.camel.builder.RouteBuilder;

@ApplicationScoped
public class MockRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        from("direct:start").to("mock:result");
    }
}

(「使用法」で説明した) CDI Bean の注入は、ネイティブモードでは機能しません。

ネイティブモードでは、テストとテスト中のアプリケーションが 2 つの異なるプロセスで実行され、それらの間でモック Bean を共有することはできません (Quarkus ドキュメント を参照)。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-mongodb</artifactId>
</dependency>

エクステンションは Quarkus MongoDB Client エクステンションを活用します。Mongo クライアントは、Quarkus MongoDB Client の 設定オプション を使用して設定できます。

Camel Quarkus MongoDB エクステンションは、camelMongoClient という名前の MongoDB クライアント Bean を自動的に登録します。これは、mongodb エンドポイント URI の connectionBean パスパラメーターで参照できます。以下に例を示します。

from("direct:start")
.to("mongodb:camelMongoClient?database=myDb&collection=myCollection&operation=findAll")

アプリケーションが複数の MongoDB サーバーと連携する必要がある場合は、「Quarkus MongoDB extension client injection」で説明するように、「特定の名前の」クライアントを作成し、クライアントおよび関連する設定を注入することで、ルートで参照できます。以下に例を示します。

//application.properties
quarkus.mongodb.mongoClient1.connection-string = mongodb://root:example@localhost:27017/

//Routes.java

    @ApplicationScoped
    public class Routes extends RouteBuilder {
        @Inject
        @MongoClientName("mongoClient1")
        MongoClient mongoClient1;

        @Override
        public void configure() throws Exception {
            from("direct:defaultServer")
                .to("mongodb:camelMongoClient?database=myDb&collection=myCollection&operation=findAll")

            from("direct:otherServer")
                .to("mongodb:mongoClient1?database=myOtherDb&collection=myOtherCollection&operation=findAll");
        }
    }

指定されたクライアントを使用する場合、「デフォルトの」camelMongoClient Bean は引き続き生成されます。詳細は、複数の MongoDB クライアント に関する Quarkus ドキュメントを参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-netty</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-platform-http</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-rest</artifactId>
</dependency>

このエクステンションは、Platform HTTP エクステンションに依存し、REST トランスポートを提供するコンポーネントとして設定します。

netty-http や servlet 等の別の REST トランスポートプロバイダーを使用するには、それぞれのエクステンションを依存関係としてプロジェクトへの追加し、RouteBuilder でプロバイダーを設定する必要があります。たとえば、servlet の場合、org.apache.camel.quarkus:camel-quarkus-servlet 依存関係を追加して、以下のようにプロバイダーを設定する必要があります。

import org.apache.camel.builder.RouteBuilder;

public class CamelRoute extends RouteBuilder {

    @Override
    public void configure() {
        restConfiguration()
                .component("servlet");
        ...
    }
}

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-salesforce</artifactId>
</dependency>

このエクステンションは、ネイティブモードでの SSL サポートを自動的に有効にします。したがって、quarkus.ssl.native=true を application.properties に追加する必要はありません。「Quarkus SSL ガイド」も参照してください。

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-saxon</artifactId>
</dependency>

上述の標準的な使用方法以外に、ネイティブモードでクラスパスリソースと共に xquery 言語およびコンポーネントを使用する場合は、テクニックが必要です。このような場合は、include-patterns オプションを指定して、ネイティブ実行可能ファイルにリソースを明示的に埋め込む必要があります。

たとえば、以下の 2 つのルートは、それぞれ myxquery.txt と another-xquery.txt という名前の 2 つのクラスパスリソースから xquery スクリプトを読み込みます。

from("direct:start").transform().xquery("resource:classpath:myxquery.txt", String.class);
from("direct:start").to("xquery:another-xquery.txt");

ネイティブモードで動作するには、include-patterns 設定を設定する必要があります。たとえば、以下のように application.properties ファイルを設定します。

quarkus.camel.native.resources.include-patterns = *.txt

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-seda</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-soap</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-sql</artifactId>
</dependency>

クラスパスからスクリプトファイルを参照するために sql または sql-stored エンドポイントを設定する場合は、以下の設定プロパティーを設定して、それらがネイティブモードで利用できるようにします。

quarkus.native.resources.includes = queries.sql, sql/*.sql

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-timer</artifactId>
</dependency>

使用方法と設定の詳細については、上記リンクを参照してください。

<dependency>
    <groupId>org.apache.camel.quarkus</groupId>
    <artifactId>camel-quarkus-xpath</artifactId>
</dependency>

標準的な使用方法以外に、ネイティブモードでクラスパスリソースと共に xpath 言語を使用する場合は、テクニックが必要です。このような場合は、include-patterns オプションを指定して、ネイティブ実行可能ファイルにリソースを明示的に埋め込む必要があります。

たとえば、以下のルートは、myxpath.txt という名前のクラスパスリソースから xpath スクリプトを読み込みます。

from("direct:start").transform().xpath("resource:classpath:myxpath.txt");

ネイティブモードで動作するには、include-patterns 設定を設定する必要があります。たとえば、以下のように application.properties ファイルを設定します。

quarkus.camel.native.resources.include-patterns = *.txt