Como a simultaneidade no Spring AMQP Listener Container é implementada?
Minha configuração XML do contêiner:
<rabbit:listener-container
connection-factory="myConnectionFactory"
acknowledge="none"
concurrency="10"
requeue-rejected="false">
<rabbit:listener ref="myListener" queues="myQueue"/>
</rabbit:listener-container>
emyListener
é apenas uma classe
@Component("myListener")
public class MyListener implements MessageListener {
@Autowired
SomeDependency dependency;
....
}
Eu especifiqueiconcurrency="10"
no meu XML. O que isto significaexatamente?
encontreialguns documentos. Eles não são tão úteis afirmando:
Especifique o número de consumidores simultâneos a serem criados. O padrão é 1.
O que me interessa é seMyListener
deve ser seguro para threads, ou seja,
SomeDependency dependency
instanciado uma vez ou para cada thread / instância?fazdependency
precisa ser thread-safe?