操作符 intercept()
从版本 5.3 开始,intercept() 运算符允许在当前流程的 MessageChannel 处注册一个或多个 ChannelInterceptor 实例。
这是通过 MessageChannels API 创建显式 MessageChannel 的替代方案。
以下示例使用 MessageSelectingInterceptor 通过异常拒绝某些消息:
.transform(...)
.intercept(new MessageSelectingInterceptor(m -> m.getPayload().isValid()))
.handle(...)