运算符 intercept()
从版本 5.3 开始,intercept()
operator 允许注册一个或多个ChannelInterceptor
实例MessageChannel
在流中。
这是创建显式MessageChannel
通过MessageChannels
应用程序接口。
以下示例使用MessageSelectingInterceptor
要拒绝某些邮件并出现例外:
.transform(...)
.intercept(new MessageSelectingInterceptor(m -> m.getPayload().isValid()))
.handle(...)