transactions - SimpleMessageListenerContainer ChannelTransacted and MaxConcurrentConsumers -
i'm trying configure simplemessagelistenercontainer spring amqp channeled transactions dynamically add consumers on demand. problem is, don't see consumers being added dynamically when have channeled transaction. clear, doesn't dynamically add consumers under load:
container.setmaxconcurrentconsumers(5); container.setchanneltransacted(true); container.settransactionmanager(rabbittransactionmanager);
but does:
container.setmaxconcurrentconsumers(5); //container.setchanneltransacted(true); //container.settransactionmanager(rabbittransactionmanager);
my questions are:
- why aren't consumers being added dynamically?
- is there workaround both channeled transactions , dynamic consumers work?
it's bug - please open jira issue.
there not workaround, unfortunately; needs patch.
the use of transactions rabbitmq quite rare, on consumer side - can explain why need them?
Comments
Post a Comment