Operator intercept()
從 5.3 版本開始,intercept()
運算子允許在流程中目前的 MessageChannel
註冊一個或多個 ChannelInterceptor
實例。這是透過 MessageChannels
API 建立明確 MessageChannel
的替代方案。以下範例使用 MessageSelectingInterceptor
拒絕某些訊息並拋出例外
.transform(...)
.intercept(new MessageSelectingInterceptor(m -> m.getPayload().isValid()))
.handle(...)