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