SimpleMessageListenerContainer ChannelTransacted и MaxConcurrentConsumers

Question

Я пытаюсь настроить SimpleMessageListenerContainer из Spring AMQP с канальными транзакциями, чтобы динамически добавлять потребителей по требованию. Проблема в том, что я не вижу, чтобы потребители добавлялись динамически, когда у меня есть транзакция с каналами. Чтобы было ясно, это не динамически добавлять потребителей под нагрузкой:

container.setMaxConcurrentConsumers(5); 
container.setChannelTransacted(true); 
container.setTransactionManager(rabbitTransactionManager); 

Но это делает:

container.setMaxConcurrentConsumers(5); 
//container.setChannelTransacted(true); 
//container.setTransactionManager(rabbitTransactionManager); 

Мои вопросы:

1. Почему не потребители добавляются динамически?
2. Есть ли обходной путь для того, чтобы заставить как транслируемые транзакции, так и динамические потребители работать?

Answer 1

1. Это ошибка - пожалуйста, откройте JIRA issue.

2. Существует, к сожалению, обходное решение; ему нужен патч.

Использование транзакций с RabbitMQ довольно редко, особенно на стороне потребителя - можете ли вы объяснить, почему они вам нужны?