0

次のように構成された特別な IntegrationFlow があります

@Bean
public IntegrationFlow setupRabbitFlow() {
    return IntegrationFlows.from(myInputChannel)     
            .handle((p, h) -> rabbitPublisher.publishToRabbit(p, h))
            .get();
}

また、一部の XML ファイルからの着信データを処理するその他のフローもあります。たとえば、Java DSL を使用したファイルからのポーリング - Files.inboundAdapter を追加するときのコンパイル エラーです。その流れの最後に、先ほどのうさぎ送りの「シンク」にメッセージを渡したいと思います。これを宣言するにはどうすればよいですか?

4

1 に答える 1