lib/sidekiq-dynamic-throttle/throttler.rb in sidekiq-dynamic-throttle-0.1.1 vs lib/sidekiq-dynamic-throttle/throttler.rb in sidekiq-dynamic-throttle-0.1.2

- old
+ new

@@ -1,8 +1,9 @@ module Sidekiq::DynamicThrottle::Throttler module ClassMethods - def sidekiq_throttle_queue(*queues) - Sidekiq::DynamicThrottle.register_throttle self, queues + def sidekiq_throttle(queue: queue, throttler: nil, **opts) + throttler ||= self + Sidekiq::DynamicThrottle.register_throttle throttler, queue end end def self.included(base) base.extend ClassMethods