スプリッター
スプリッターを作成するには、split()
EIP メソッドを使用します。デフォルトでは、ペイロードが Iterable
、Iterator
、Array
、Stream
、リアクティブ Publisher
の場合、split()
メソッドは各アイテムを個別のメッセージとして出力します。ラムダ、SpEL 式、AbstractMessageSplitter
実装を受け入れます。または、パラメーターなしで使用して DefaultMessageSplitter
を提供できます。次の例は、ラムダを提供して splitWith()
メソッドを使用する方法を示しています。
@Bean
public IntegrationFlow splitFlow() {
return IntegrationFlow.from("splitInput")
.splitWith(s -> s.applySequence(false).delimiters(","))
.channel(MessageChannels.executor(taskExecutor()))
.get();
}
上記の例では、コンマ区切りの String
を含むメッセージを分割するスプリッターを作成します。
ラムダと Message<?>
引数も参照してください。