第257章 リアクティブストリームコンポーネント

Camel バージョン 2.19 から利用可能

reactive-streams: コンポーネントを使用すると、リアクティブストリーム標準と互換性のあるリアクティブストリーム処理ライブラリーを持つメッセージを交換できます。http://www.reactive-streams.org/

コンポーネントはバックプレシャーをサポートしており、リアクティブストリーム技術互換性キット(TCK) を使用してテストされました。

Camel モジュールは、ユーザーが Camel ルート内で受信および送信 ストリームを定義できるようにするリアクティブ ストリームコンポーネントと、Camel エンドポイントを外部のリアクティブフレームワークに直接使用できるようにするダイレクトクライアント API を提供します。

Camel はリアクティブストリームと サブスクライバー の内部実装 を 使用するため、特定のフレームワークには関係ありません。統合テストでは、Reactor Core 3、RxJava 2 のリアクティブフレームワークが使用されています。

Maven ユーザーは、このコンポーネントの pom.xml に以下の依存関係を追加する必要があります。

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-reactive-streams</artifactId>
    <version>x.x.x</version>
    <!-- use the same version as your Camel core version -->
</dependency>

reactive-streams://stream?[options]