2017-05-30 1 views
0

Je veux consommer des données de rabbitMQ file d'attente avec akka stream (Java). J'ai pris l'aide du lien suivant: http://developer.lightbend.com/docs/alpakka/latest/amqp.htmlconsommateur de flux akka de rabbitmq avec connecteur AMQP

Je voudrais savoir sur le flux d'accusé de réception à rabbitMQ après que l'élément est consommé. Puis-je consommer l'élément en parallèle?

(Java extrait sera très utile)

Merci

+0

Pouvez-vous clarifier s'il vous plaît? Y at-il quelque chose de spécifique que vous recherchez et que la documentation sur les remerciements ne fournit pas? – theMayer

+0

Je veux consommer du lapin avec un jet d'akka. J'ai trouvé que le flux akka avec le connecteur amqp, fait d'abord sortir l'élément de la file d'attente, envoie l'accusé de réception à la file d'attente, puis envoie l'élément en aval (flux akka) à consommer. –

+0

Je veux cet accusé de réception dans mon contrôle. Est-ce possible? –

Répondre

2

Le connecteur actuel Alpakka AMQP fait ACKing naïve des messages dès qu'ils sont émis en aval, il y a un suivi de billets en ajoutant une solution plus souple que vous pouvez suivre ici : https://github.com/akka/alpakka/issues/97

+0

Oui .. Merci ... –