To be able to use the Single Active Consumer feature (to be used in https://github.com/twingly/nile/issues/94) we need to be able to set the x-single-active-consumer argument when declaring a queue.
How we setup the queue arguments now:
|
def queue_options |
|
{ |
|
durable: true, |
|
arguments: queue_arguments, |
|
} |
|
end |
|
|
|
def queue_arguments |
|
{}.tap do |arguments| |
|
arguments["x-max-length"] = @max_length if @max_length |
|
end |
|
end |
Either we just add that argument like we did for x-max-length, or make sure the user can add any arguments they like.
To be able to use the Single Active Consumer feature (to be used in https://github.com/twingly/nile/issues/94) we need to be able to set the
x-single-active-consumerargument when declaring a queue.How we setup the queue arguments now:
twingly-amqp/lib/twingly/amqp/subscription.rb
Lines 99 to 110 in 59a2359
Either we just add that argument like we did for
x-max-length, or make sure the user can add any arguments they like.