contributte / rabbitmq

🐰 RabbitMQ (AMQP, STOMP, MQTT) using BunnyPHP for Nette Framework (@nette).
https://contributte.org/packages/contributte/rabbitmq.html
MIT License
24 stars 25 forks source link

Added support for `MESSAGE_ACK_AND_TERMINATE` #41

Closed jakubvojacek closed 3 years ago

jakubvojacek commented 3 years ago

Limiting the consumer by the number of messages or number of seconds is not ideal in my use case

we want for the consumer to run for a fixed amount of time, eg 1 hour but we cannot afford to kill the consumer after given time of seconds due to the way we process the items - depending on the traffix we're queuing the messages inside the consumer and we're processing them in batches.

Having the option ACK_TERMINATE will allow us to kill the consumer whenever we want to

paveljanda commented 3 years ago

Okey, cool :)