此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring Integration 6.4.0! |
运算符 intercept()
从版本 5.3 开始,该 operator 允许在 flow 中的当前位置注册一个或多个实例。
这是通过 API 创建 explicit 的替代方法。
以下示例使用 a 拒绝某些邮件,但存在异常:intercept()
ChannelInterceptor
MessageChannel
MessageChannel
MessageChannels
MessageSelectingInterceptor
.transform(...)
.intercept(new MessageSelectingInterceptor(m -> m.getPayload().isValid()))
.handle(...)