Kann pro Einzelverbraucher sein, kann aber für mehrere Verbraucher gleichzeitig eingestellt werden. Suchen Sie einfach nach Titel Beispiel - Einzelverbraucherhere. Also AMQP unterstützt es. Ich bin mir nicht sicher für die Bibliothek, die Sie erwähnt haben, aber auf offizieller Java-Bibliothek ist es so - transparent gegenüber AMQPs basic.qos-Methode. Ebenfalls aus der oben genannten Verbindung
beachten, dass der Standardwert für die globale Flag in den meisten APIs falsch ist
und für rabbitmq wenn global == false
prefetch_count separat angewendet zu jedem neuen Verbraucher auf dem Kanal
so müssten Sie herausfinden, wie Es ist in dieser Bibliothek implementiert.
betrachten Additionaly amqp.node Bibliothek verwenden, da diese eine auf rabbimtq Tutorials verwendet wird. (EDIT Ich sehe jetzt nur, dass Derick Bailey das schon erwähnt hat.)
FWIW - Sie sollten nicht Knoten-amqp verwenden. Diese Bibliothek weist eine Anzahl bekannter Speicherlecks und Fehler auf, die schwerwiegende Probleme verursachen. das RabbitMQ Team empfiehlt „amqplib“ (aka amqp.node) statt: https://github.com/squaremo/amqp.node –