该版本仍在开发中,尚未被视为稳定。对于最新的稳定版本,请使用 Spring Integration 7.0.0spring-doc.cadn.net.cn

MessageChannelSpec.wireTap()

春季集成包括.wireTap()流流 API消息通道规范建设者。 以下示例展示了如何使用窃听记录输入的方法:spring-doc.cadn.net.cn

@Bean
public QueueChannelSpec myChannel() {
    return MessageChannels.queue()
            .wireTap("loggingFlow.input");
}

@Bean
public IntegrationFlow loggingFlow() {
    return f -> f.log();
}

如果消息频道是 的一个实例拦截频道log(),wireTap()拦截()对电流施加算符消息频道. 否则,是中间式直达频道注入当前配置端点的流程中。 在以下示例中,窃听拦截机被添加到我的频道直接来说,因为直达频道实现拦截频道:spring-doc.cadn.net.cn

@Bean
MessageChannel myChannel() {
    return new DirectChannel();
}

...
    .channel(myChannel())
    .log()
}

当电流消息频道不实现拦截频道,一个隐式直达频道桥接处理者被注射到中集成流程,以及窃听新增直达频道. 以下示例没有任何信道声明:spring-doc.cadn.net.cn

.handle(...)
.log()
}

在前述例子中(以及任何未声明通道时),隐式直达频道被注入在当前位置集成流程并用作当前配置的输出通道服务激活处理器(摘自.handle()前面描述的)。spring-doc.cadn.net.cn