如需使用最新稳定版本，请使用 Spring Integration 7.0.4！spring-doc.cadn.net.cn

操作符 intercept()

从版本 5.3 开始，intercept() 运算符允许在当前 MessageChannel 中注册一个或多个 ChannelInterceptor 实例。这是通过 MessageChannels API 显式创建 MessageChannel 的替代方案。以下示例使用 MessageSelectingInterceptor 以异常方式拒绝某些消息：spring-doc.cadn.net.cn

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