DefaultMQPushConsumer setConsumeThreadPool spring-cloud-starter-stream-rocketmq 支持的maven版本是多少
时间: 2024-01-05 21:02:07 浏览: 63
`spring-cloud-starter-stream-rocketmq` 是基于 Spring Cloud Stream 封装的 RocketMQ 消息驱动框架,它的版本号与所依赖的 RocketMQ 版本号有所关联。在 `spring-cloud-starter-stream-rocketmq` 中,可以通过在 `pom.xml` 文件中指定 RocketMQ 的版本号来选择使用不同的 RocketMQ 版本。
在 `spring-cloud-starter-stream-rocketmq` 中,可以通过以下方式引入 RocketMQ 的依赖:
```xml
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>${rocketmq.version}</version>
</dependency>
```
其中 `${rocketmq.version}` 为 RocketMQ 的版本号,可以通过在 `pom.xml` 文件中指定来选择使用不同的 RocketMQ 版本。
需要注意的是,`spring-cloud-starter-stream-rocketmq` 是一个基于 Spring Cloud Stream 封装的 RocketMQ 消息驱动框架,它并不直接提供 `DefaultMQPushConsumer` 的 API 方法,因此 `setConsumeThreadPool` 方法也不会直接暴露出来。如果您需要使用自定义消费线程池的功能,可以考虑使用 `spring-cloud-starter-stream-rocketmq-core` 包中提供的 `RocketMQListenerContainer` 类来实现。
阅读全文