第 273 章 被动流组件

从 Camel 版本 2.19 开始提供

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

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

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

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]