lib/ears/consumer.rb in ears-0.13.0 vs lib/ears/consumer.rb in ears-0.14.0
- old
+ new
@@ -38,10 +38,9 @@
# @option opts [Boolean] :retry_queue (false) Whether a retry queue should be provided.
# @option opts [Integer] :retry_delay (5000) The delay in milliseconds before retrying a message.
# @option opts [Boolean] :error_queue (false) Whether an error queue should be provided.
# @option opts [Boolean] :durable_exchange (true) Whether the exchange should be durable.
# @option opts [Symbol] :exchange_type (:topic) The type of exchange to use.
- # @option opts [Integer] :threads (1) The number of threads to use for this consumer.
def self.configure(opts = {})
self.queue = opts.fetch(:queue)
self.exchange = opts.fetch(:exchange)
self.routing_keys = opts.fetch(:routing_keys)
self.queue_options = queue_options_from(opts: opts)