273장. Reactive Streams 구성 요소

Camel 버전 2.19로 사용 가능

reactive-streams: 구성 요소를 사용하면 reactive stream standard와 호환되는 reactive stream processing 라이브러리와 메시지를 교환할 수 있습니다.

이 구성 요소는 백압을 지원하며 TCK(reactive streams technology compatibility Kit) 를 사용하여 테스트되었습니다.

Camel 모듈은 사용자가 Camel 경로 내에서 수신 및 발신 스트림을 정의할 수 있는 reactive-streams 구성 요소와 Camel 끝점을 외부 반응 프레임워크에 직접 사용할 수 있는 직접 클라이언트 API를 제공합니다.

Camel은 reactive streams 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]