Клиент ActiveMQ Spring: как изменить пул процессоров?

У нас есть клиент ActiveMQ 5.10 и JMS в Spring 4.0 через Maven, например:

    <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 потоков для обработки сообщений из очереди?


java spring spring-jms activemq
person Artem    schedule 10.10.2014    source источник
comment
покажите вашу текущую конфигурацию, пожалуйста. Документ довольно ясно об этом, если я неправильно понял ваш вопрос (проверьте атрибут concurrency). Обратите внимание, что вы можете установить его для элемента jms:listener начиная с Spring 4.1. При обновлении вы также можете использовать новую аннотированную инфраструктуру конечных точек.   -  person Stephane Nicoll    schedule 10.10.2014
comment
Потрясающе, спасибо. Вот оно!   -  person Artem    schedule 11.10.2014
comment
@StéphaneNicoll, не могли бы вы опубликовать свой ответ, чтобы я мог его принять?   -  person Artem    schedule 11.10.2014

Ответы (1)


arrow_upward
1
arrow_downward

Документация довольно ясно об этом, если я неправильно понял ваш вопрос (проверьте атрибут concurrency).

Обратите внимание, что вы можете установить его на jms:listener element только с Spring 4.1. При обновлении вы также можете использовать новую аннотированную инфраструктуру конечных точек.

person Stephane Nicoll    schedule 11.10.2014