我们通过Maven在Spring 4.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个线程来处理来自队列的消息?
除非我误解了您的问题(请检查concurrency
属性),否则文档非常明确。
请注意,您只能在jms:listener element
Spring 4.1的as上进行设置。如果升级,则还可以使用新的带注释的终结点基础结构。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句