1
キューがRabbitMQで保持できるメッセージの最大数を制限する方法はありますか?RabbitMQ - キュー内のメッセージ数を制限する方法はありますか?
たとえば、この番号が10に設定され、現在のサイズが10の場合、新しいメッセージがキュー(FIFO)にプッシュされると、最も古いメッセージが破棄されます。
キューがRabbitMQで保持できるメッセージの最大数を制限する方法はありますか?RabbitMQ - キュー内のメッセージ数を制限する方法はありますか?
たとえば、この番号が10に設定され、現在のサイズが10の場合、新しいメッセージがキュー(FIFO)にプッシュされると、最も古いメッセージが破棄されます。
はいX-MAX-length属性と、そこにある:
Map<String, Object> args = new HashMap<String, Object>();
args.put("x-max-length", 10);
channel.queueDeclare("myqueue", false, false, false, args);
ます。またrabbitmqctlでそれのためのポリシーを設定することによってこれをachiveことができます。
rabbitmqctl set_policy Ten ".*" '{"max-length":10}' --apply-to queues
最も古いメッセージは時にドロップされます新しいものが登場します。