运算符 intercept()

从版本 5.3 开始,intercept()operator 允许注册一个或多个ChannelInterceptor实例MessageChannel在流中。 这是创建显式MessageChannel通过MessageChannels应用程序接口。 以下示例使用MessageSelectingInterceptor要拒绝某些邮件并出现例外:spring-doc.cadn.net.cn

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