¿Cómo se implementa la concurrencia en Spring AMQP Listener Container?
Mi contenedor de configuración XML:
<rabbit:listener-container
connection-factory="myConnectionFactory"
acknowledge="none"
concurrency="10"
requeue-rejected="false">
<rabbit:listener ref="myListener" queues="myQueue"/>
</rabbit:listener-container>
ymyListener
es solo una clase
@Component("myListener")
public class MyListener implements MessageListener {
@Autowired
SomeDependency dependency;
....
}
He especificadoconcurrency="10"
en mi XML Qué significa estoexactamente?
He encontradoalgunos documentos. No son tan útiles diciendo:
Especifique el número de consumidores concurrentes para crear. El valor predeterminado es 1.
Lo que me interesa es siMyListener
tiene que ser seguro para subprocesos, es decir
SomeDependency dependency
instanciado una vez o para cada hilo / instancia?hacedependency
necesita ser seguro para hilos?