java - ActiveMQ Spring客户端: How to change processors pool?

标签 java spring activemq spring-jms

我们通过 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 个线程来处理队列中的消息?

最佳答案

The documentation除非我误解了你的问题,否则它是非常明确的(检查并发属性)。

请注意,您只能从 Spring 4.1 开始在 jms:listener 元素 上设置它。如果您升级,您还可以使用新的带注释的端点基础设施

关于java - ActiveMQ Spring客户端: How to change processors pool?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/26291245/

相关文章:

java - 为什么在填充和组装二维数组矩阵时会出现错误?

java - 有什么方法可以知道执行字节代码时 JVM 的速度吗?

java - Autowiring 工厂创建实例的 spring 方法是什么?

java - Hazelcast Map TTL 不适用于 spring 缓存抽象

c# - 如何构建嵌入式ActiveMQ Broker?

java - map 并发修改问题

java - 如何验证字符串是否为字符串而不是 java 中的整数?

java - 消息部分 MyClass 未被识别。 (它存在于服务 WSDL 中吗?)

activemq - 无法连接到 ActiveMQ 服务器 - activemq for mcollective 失败

java - jms onMessage() 暂停操作,直到收到消费信号