Как реализуется параллелизм в контейнере прослушивателя Spring AMQP?
Конфигурация моего контейнера XML:
<rabbit:listener-container
connection-factory="myConnectionFactory"
acknowledge="none"
concurrency="10"
requeue-rejected="false">
<rabbit:listener ref="myListener" queues="myQueue"/>
</rabbit:listener-container>
а такжеmyListener
это просто класс
@Component("myListener")
public class MyListener implements MessageListener {
@Autowired
SomeDependency dependency;
....
}
Я указалconcurrency="10"
в моем XML. Что это значитименно так?
я обнаружилнекоторые документы, Они не так полезны, заявив:
Укажите количество одновременных потребителей для создания. По умолчанию 1.
Что меня интересует, так этоMyListener
должен быть потокобезопасным, т.е.
SomeDependency dependency
создается один раз или для каждого потока / экземпляра?делаетdependency
нужно быть потокобезопасным?