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