对于最新的稳定版本,请使用 Spring Integration 6.4.0! |
RabbitMQ 流队列支持
版本 6.0 引入了对 RabbitMQ 流队列的支持。
这些端点的 DSL 工厂类是 .RabbitStream
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"));
}