Spring JMS@JmsListener一种方法的另一种并发性

Question

如何通过@JmsListener仅更改一种方法的默认并发？我已将并发添加到@JmsListener（如下所示），但“JBoss管理控制台运行时JMS队列指标”中没有任何更改。我有JBoss 6.4，Spring JMS版本4.3.1。发布。

我的听众：

@JmsListener(containerFactory = "myJmsQueueListenerContainerFactory", destination = "some.destination", concurrency = "3-10")
@SendTo("some.place")
public TransactionBookingStatus bookTransaction(Message message) throws JMSException {
    //my implementation
}

我的默认配置：

@Bean
public JndiObjectFactoryBean jmsConnectionFactoryFactoryBean() {
    JndiObjectFactoryBean factory = new JndiObjectFactoryBean();
    factory.setJndiName("java:/ConnectionFactory");

    return factory;
}

public ConnectionFactory jmsConnectionFactory() {
    return (ConnectionFactory) jmsConnectionFactoryFactoryBean().getObject();
}

@Bean
public JmsTemplate testMessageTemplate() {
    JmsTemplate tmpl = new JmsTemplate();

    tmpl.setConnectionFactory(jmsConnectionFactory());

    return tmpl;
}

@Bean
public DefaultJmsListenerContainerFactory myJmsQueueListenerContainerFactory() {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(jmsConnectionFactory());
    factory.setConcurrency("3-40");

    factory.setErrorHandler(new TrnJmsErrorHandler());

    return factory;
}

Answer 1

您所拥有的应该可以工作-打开org的调试日志记录。springframework。jms，您将看到关于消费者管理的消息-确保在日志配置中包括线程，您将看到3个消费者线程。

编辑

@SpringBootApplication
public class So40908517Application {

    public static void main(String[] args) throws Exception {
        ConfigurableApplicationContext context = SpringApplication.run(So40908517Application.class, args);
        JmsTemplate template = context.getBean(JmsTemplate.class);
        for (int i = 0; i < 3; i++) {
            template.convertAndSend("foo", "bar");
        }
        context.getBean(CountDownLatch.class).await();
        context.close();
    }

    @Bean
    public CountDownLatch latch() {
        return new CountDownLatch(3);
    }

    @JmsListener(destination = "foo", concurrency = "3-40")
    public void listen(String in) {
        System.out.println(in + " received on " + Thread.currentThread().getName());
        latch().countDown();
    }

}

结果（预期3个线程）：

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
=========|_|==============|___/=/_/_/_/
:: Spring Boot ::        (v1.4.2.RELEASE)

bar received on DefaultMessageListenerContainer-3
bar received on DefaultMessageListenerContainer-2
bar received on DefaultMessageListenerContainer-1