スプリッター
スプリッターを作成するには、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<?> 引数も参照してください。