module Sidekiq::Throttled::QueueName
Queue name utility belt.
@private
Constants
- QUEUE_NAME_PREFIX_RE
RegExp used to stip out any redisr-namespace prefixes with `queue:`.
Public Class Methods
expand(queue)
click to toggle source
Prepends `queue:` prefix to given `queue` name.
@note It does not normalizes queue before expanding it, thus
double-call of this method will potentially do some harm.
@param [#to_s] queue Queue name @return [String]
# File lib/sidekiq/throttled/queue_name.rb, line 40 def expand(queue) -"queue:#{queue}" end
normalize(queue)
click to toggle source
Strips redis-namespace and `queue:` prefix from given queue name.
@example
QueueName.normalize "queue:default" # => "default" QueueName.normalize "queue:queue:default" # => "default" QueueName.normalize "foo:bar:queue:default" # => "default"
@param [#to_s] @return [String]
# File lib/sidekiq/throttled/queue_name.rb, line 29 def normalize(queue) -queue.to_s.sub(QUEUE_NAME_PREFIX_RE, "") end