運算子 intercept()

從 5.3 版本開始,intercept() 運算子允許在當前流中的 MessageChannel 上註冊一個或多個 ChannelInterceptor 例項。這是透過 MessageChannels API 建立顯式 MessageChannel 的替代方案。以下示例使用 MessageSelectingInterceptor 來拒絕丟擲異常的特定訊息。

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