스프링 통합 채널의 소비자 배치

PollableChannel에서 한 번에 여러 메시지를 소비하는 아웃 바운드 채널 어댑터 또는 게이트웨이를 정의하는 방법을 Spring 통합 문서에서 찾을 수 없었습니다.스프링 통합 채널의 소비자 배치

수집기를 사용하여 메시지를 목록에 결합 할 수 있습니까?

2014-09-30 Mikhail Tsaplin

사실입니다. 어떤 메시징도 한 번에 하나의 메시지만으로 거래를하기 때문에 다른 메시지에 영향을 미치지 않으므로 그러한 구성 요소는 실제로 없습니다.

하나 개의 채널이 비슷한을 제공하지 않습니다 ...

EIP catalog을 다른 자성 등 서로 다른 비즈니스 로직에 대한 서로 다른 시스템에서 다른 메시지를 받아 들일 수 있지만, 나는 당신의 요구 사항은 window 또는 buffer에서 같은 생각 Reactive Streams.

오른쪽, Aggregator이 여기에 도움이 될 수 있습니다. 인공물을 correlationKey (correlation-strategy-expression="1") 개만두고 batch 방출 전략을 제공하면됩니다.

Reactor Spring Extension에는 Batcher 구현이 너무 유용합니다.

출처

2014-09-30 08:34:54

-1

스프링 통합에는 이러한 종류의 대기열에 대한 MessageChannels 구현이 있습니다. 구현 중 하나는 "PublishSubscribeChannel"입니다. 이것이 원하는 것일 수 있습니다.

http://docs.spring.io/spring-integration/reference/html/messaging-channels-section.html

출처

2014-09-30 08:14:21

PubSubChannel을 구성하여 구독자 용 메시지 묶음을 만들 수 있습니까 ?? –

AFAIK, 모든 유형의 메시징이 단일 메시지를 처리하도록 설계되었다고 말하는 것은 옳지 않습니다. JMS는 Java 메시징 프로토콜이며 게시/구독 모델 채널을 명확하게 정의합니다. 구현은에서 볼 수 있습니다. 예제 프로젝트를 참조하십시오. 내가 제안한 것을 위해. [link] https://github.com/benjaminwootton/spring-integration-examples/blob/master/target/classes/publish-subscribe-channel-example.xml –

스프링 통합 채널의 소비자 배치

답변

관련 문제