操作符 intercept()
从 5.3 版本开始,intercept()
操作符允许在当前流中的 MessageChannel
上注册一个或多个 ChannelInterceptor
实例。这是通过 MessageChannels
API 创建显式 MessageChannel
的替代方案。以下示例使用 MessageSelectingInterceptor
来拒绝抛出异常的特定消息。
.transform(...)
.intercept(new MessageSelectingInterceptor(m -> m.getPayload().isValid()))
.handle(...)