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