Operator intercept()

从 5.3 版开始，intercept() 运算符允许在流中的当前 MessageChannel 中注册一个或多个 ChannelInterceptor 实例。这是一种通过 MessageChannels API 创建显式 MessageChannel 的替代方法。以下示例使用了一个 MessageSelectingInterceptor 来拒绝带有异常的特定消息：

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