第 273 章 主动流组件

从 Camel 版本 2.19 开始提供

reactive-streams: 组件允许您使用与被动流标准兼容的重新主动流处理库交换消息。http://www.reactive-streams.org/

组件支持后端，并使用 被动流技术兼容性工具包(TCK) 测试。

Camel 模块提供了一个 reactive-streams 组件，允许用户在 Camel 路由中定义传入和传出流，以及允许将 Camel 端点直接用于任何外部主动框架的直接客户端 API。

Camel 使用重新主动流 publisher 和 Subscriber 的内部实现，因此它不与任何特定的框架关联。集成测试中使用了以下被动框架： 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]