Pouvons-nous changer les propriétés de lapin et config spring print

Question

Dans mon POC, j'utilise Spring Cloud Config et Spring Stream Rabbit. Je veux changer dynamiquement le nombre d'auditeurs (concurrence). Est-il possible de faire ça? Je veux faire ce qui suit:

1) S'il y a trop de messages dans la file d'attente, je veux augmenter le niveau de concurrence.

2) Dans un scénario où mon système en aval n'est pas disponible, je veux arrêter le traitement des messages de la file d'attente (en court-circuitant le niveau de concurrence 0).

Comment puis-je y parvenir?

Merci pour votre aide.

Answer 1

Le conteneur d'écoute qui s'exécute dans le classeur prend en charge de tels changements (bien que vous ne puissiez pas descendre à 0, mais le conteneur peut être stop() ped). Toutefois, spring-cloud-stream ne fournit aucun mécanisme permettant d'obtenir une référence au conteneur d'écoute.

Vous pouvez envisager d'utiliser un @RabbitListener à partir de Spring AMQP à la place - il vous donnera un contrôle complet sur le conteneur d'écoute.