270.7. reactive 프레임워크로 Camel 데이터 처리

리 액 티브 스트림 게시자를 통해 양방향 방식으로 데이터를 교환할 수 있지만 Camel 경로는 종종 in-out exchange 패턴을 사용합니다(예: REST 엔드포인트 정의 및 일반적으로 각 요청에 응답 필요).

이러한 상황에서 사용자는 실시간 처리 단계를 흐름에 추가하여 Camel 경로를 개선하거나 반응형 프레임워크를 사용하여 전체 변환을 정의할 수 있습니다.

예를 들어 다음 경로가 제공됩니다. 

from("timer:clock")
.setBody().header(Exchange.TIMER_COUNTER)
.to("direct:reactive")
.log("Continue with Camel route... n=${body}");

reactive processing step은 "direct:reactive" 엔드포인트에 연결될 수 있습니다. 

CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);

camel.process("direct:reactive", Integer.class, items ->
    Flowable.fromPublisher(items) // RxJava2
        .map(n -> -n)); // make every number negative

Camel 경로에서 데이터 흐름은 외부 반응 프레임워크에서 처리한 후 Camel 내부의 처리 흐름을 계속합니다.

이 메커니즘은 완전히 반응형 방식으로 인-Out exchange를 정의하는 데에도 사용할 수 있습니다. 

CamelReactiveStreamsService camel = CamelReactiveStreams.get(context);

// requires a rest-capable Camel component
camel.process("rest:get:orders", exchange ->
                    Flowable.fromPublisher(exchange)
                            .flatMap(ex -> allOrders())); // retrieve orders asynchronously

자세한 내용은 Camel 예제(camel-example-reactive-streams)를 참조하십시오.