对于最新的稳定版本，请使用 Spring Integration 6.4.0！spring-doc.cn

运算符 intercept（）

从版本 5.3 开始，该 operator 允许在 flow 中的当前位置注册一个或多个实例。这是通过 API 创建 explicit 的替代方法。以下示例使用 a 拒绝某些邮件，但存在异常：intercept()ChannelInterceptorMessageChannelMessageChannelMessageChannelsMessageSelectingInterceptorspring-doc.cn

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