AMQPコネクタ付きウサギmqのアコカストリームコンシューマ

rabbitMQキューのデータをakka stream（Java）で消費したいです。私はリンクをたどってから助けを取った：http://developer.lightbend.com/docs/alpakka/latest/amqp.html AMQPコネクタ付きウサギmqのアコカストリームコンシューマ

私は要素が消費された後にrabbitMQへの承認フローについて知りたいです。

要素を並列に使用できますか？

おかげ

出典

2017-05-30 Nihar_rathod

あなたは明確にしていただけますか？謝辞に関する文書が提供していない、あなたが探している特定のものがありましたか？ – theMayer

私はakkaストリームでrabbitmqを使いたいです。私は、amqpコネクタを持つakkaストリームは、最初にキューから要素をポップし、キューに確認応答を送信し、次に要素を下流（akkaストリーム）に消費するように送信します。 –

私はこの承認を私の管理下に置いておきたいと思います。これは可能ですか？ –

（Java断片は本当に参考になります）現在Alpakka AMQPコネクタ行い、彼らはあなたがここに従うことができ、より柔軟なソリューションを追加したチケットトラッキングがあり、下流に放出されるとすぐにメッセージの素朴な肯定応答（ACK）：https://github.com/akka/alpakka/issues/97

出典

2017-06-08 10:18:38 johanandren

はい..ありがと... –

AMQPコネクタ付きウサギmqのアコカストリームコンシューマ

答えて

関連する問題