このバージョンはまだ開発中であり、まだ安定しているとは見なされていません。最新の安定バージョンについては、Spring Integration 6.5.3 を使用してください！

オペレーター intercept()

バージョン 5.3 以降、intercept() 演算子を使用すると、フロー内の現在の MessageChannel に 1 つ以上の ChannelInterceptor インスタンスを登録できます。これは、MessageChannels API を介して明示的に MessageChannel を作成する代わりに使用できます。次の例では、MessageSelectingInterceptor を使用して特定のメッセージを例外付きで拒否しています。

.transform(...)
.intercept(new MessageSelectingInterceptor(m -> m.getPayload().isValid()))
.handle(...)