此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring Integration 6.5.1! |
运算符 intercept()
从 5.3 版开始,intercept()
运算符允许注册一个或多个ChannelInterceptor
实例在当前MessageChannel
在流动中。
这是创建显式MessageChannel
通过MessageChannels
应用程序接口。
以下示例使用MessageSelectingInterceptor
要拒绝某些邮件并出现异常:
.transform(...)
.intercept(new MessageSelectingInterceptor(m -> m.getPayload().isValid()))
.handle(...)