通过Maven,我们在Spring4.0中有了ActiveMQ 5.10和JMS,如下所示:
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-spring</artifactId>
<version>5.10.0</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>4.1.0.RELEASE</version>
</dependency>通过实例化ActiveMQConnectionFactory在代码中进行配置。
我们希望限制队列处理的吞吐量,保持大容量或无限插入。
如何设置连接器,使其能够使用1000个出站连接,但不超过2个线程来处理来自队列的消息?
发布于 2014-10-11 08:22:48
文献资料对此非常明确,除非我误解了您的问题(查看concurrency属性)。
请注意,您只可以从Spring4.1开始在jms:listener element上设置它。如果升级,还可以使用新的带注释的端点基础结构。
https://stackoverflow.com/questions/26291245
复制相似问题