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