MessageChannelSpec.wireTap()
Spring Integration 包含一个 .wireTap() 流式 API MessageChannelSpec 构建器。
以下示例展示了如何使用 wireTap 方法来记录输入:
@Bean
public QueueChannelSpec myChannel() {
return MessageChannels.queue()
.wireTap("loggingFlow.input");
}
@Bean
public IntegrationFlow loggingFlow() {
return f -> f.log();
}
如果 MessageChannel 是 InterceptableChannel 的实例,则 log()、wireTap() 或 intercept() 操作符将应用于当前的 MessageChannel。
否则,一个中间的 DirectChannel 会被注入到流中,用于当前配置的端点。
在以下示例中,WireTap 拦截器直接添加到 myChannel,因为 DirectChannel 实现了 InterceptableChannel:
@Bean
MessageChannel myChannel() {
return new DirectChannel();
}
...
.channel(myChannel())
.log()
}
当当前的 MessageChannel 没有实现 InterceptableChannel 时,一个隐式的 DirectChannel 和 BridgeHandler 会被注入到 IntegrationFlow 中,并且 WireTap 会被添加到这个新的 DirectChannel。
以下示例没有任何通道声明:
.handle(...)
.log()
}
在前面的示例中(以及任何没有声明通道的情况下),一个隐式的 DirectChannel 会被注入到 IntegrationFlow 的当前位置,并用作当前配置的 ServiceActivatingHandler 的输出通道(来自 .handle(),前面已述)。