Sneakers-Max-Retry-Handler
A modified max retry handler for RabbitMQ and Sneakers
A small modification of Sneaker's built-in Maxretry class
the replacement class is called SneakersMaxRetryHandler::Maxretry
has the exact same logic, but you can pass arguments for handler created queues
Installation
Include it in your Gemfile.
gem 'sneakers_max_retry_handler'
Next install it with Bundler.
$ bundle install
Use:
initialize your worker with the Maxretry handler, pass arguments for retry and error queues:
class MyWorker
from_queue 'audit_service', {
handler: SneakersMaxRetryHandler::Maxretry,
retry_arguments: { 'x-queue-type': 'quorum' },
error_arguments: { 'x-queue-type': 'quorum' }
}
end