Operator intercept()

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

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