如需使用最新稳定版本，请使用 Spring Integration 7.0.4！spring-doc.cadn.net.cn

RabbitMQ 流队列支持

版本 6.0 增加了对 RabbitMQ 流队列的支持。spring-doc.cadn.net.cn

这些端点的 DSL 工厂类是 RabbitStream。spring-doc.cadn.net.cn

RabbitMQ 流式入站通道适配器

@Bean
IntegrationFlow simpleStream(Environment env) {
	return IntegrationFlow.from(RabbitStream.inboundAdapter(env).streamName("my.stream"))
			// ...
			.get();
}

@Bean
IntegrationFlow superStream(Environment env) {
	return IntegrationFlow.from(RabbitStream.inboundAdapter(env).superStream("my.super.stream", "my.consumer"))
			// ...
			.get();
}

RabbitMQ 流式出站通道适配器

@Bean
IntegrationFlow outbound(Environment env) {
    return f -> f
            // ...
            .handle(RabbitStream.outboundStreamAdapter(env, "my.stream"));

}