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)