次のように構成された特別な IntegrationFlow があります
@Bean
public IntegrationFlow setupRabbitFlow() {
return IntegrationFlows.from(myInputChannel)
.handle((p, h) -> rabbitPublisher.publishToRabbit(p, h))
.get();
}
また、一部の XML ファイルからの着信データを処理するその他のフローもあります。たとえば、Java DSL を使用したファイルからのポーリング - Files.inboundAdapter を追加するときのコンパイル エラーです。その流れの最後に、先ほどのうさぎ送りの「シンク」にメッセージを渡したいと思います。これを宣言するにはどうすればよいですか?