私はプロジェクトでRabbitMQWeb-STOMPを使用しており、それは私にとって非常に良いことですが、1つの問題があります。コンシューマーがキューにサブスクライブすると、キューからすべてのメッセージが即座に取得されます。私の場合、メッセージタスクには時間がかかる可能性があり、前のメッセージが完了したときにのみ、コンシューマーがキューから次のメッセージを取得する必要があります。
コンシューマーがサブスクライブされた後に公開が開始されると、すべて正常に機能しますが、既にキューにメッセージがある場合、最初にサブスクライブされたコンシューマーはすべてのメッセージを取得し、他のコンシューマーは無料のままになります。前のメッセージがACKされたときにのみ次のメッセージを消費するnode-amqpqueue.shift()メソッドのようなものはありますか?