跳到主要内容

操作 intercept()

QWen Plus 中英对照 Operator intercept()

从 5.3 版本开始,intercept() 操作符允许在流中的当前 MessageChannel 注册一个或多个 ChannelInterceptor 实例。这是通过 MessageChannels API 显式创建 MessageChannel 的替代方法。以下示例使用 MessageSelectingInterceptor 来通过抛出异常拒绝某些消息:

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