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