Wie wird die Parallelität in Spring AMQP Listener Container implementiert?
Meine Container-XML-Konfiguration:
<rabbit:listener-container
connection-factory="myConnectionFactory"
acknowledge="none"
concurrency="10"
requeue-rejected="false">
<rabbit:listener ref="myListener" queues="myQueue"/>
</rabbit:listener-container>
undmyListener
ist nur eine Klasse
@Component("myListener")
public class MyListener implements MessageListener {
@Autowired
SomeDependency dependency;
....
}
Ich habe angegebenconcurrency="10"
in meinem XML. Was bedeutet dasgenau?
Ich habe gefundenEinige Dokumente. Sie sind nicht so hilfreich und sagen:
Geben Sie die Anzahl der gleichzeitig zu erstellenden Konsumenten an. Standard ist 1.
Was mich interessiert ist obMyListener
muss threadsicher sein, d.h.
SomeDependency dependency
einmal oder für jeden Thread / jede Instanz instanziiert?tutdependency
müssen thread sicher sein?