RabbitMQ Stream Queue 支援

6.0 版本引入了對 RabbitMQ Stream Queue 的支援。

這些端點的 DSL 工廠類是 RabbitStream。

RabbitMQ Stream 入站通道介面卡

@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 Stream 出站通道介面卡

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

}