lib/sidekiq/throttled/queue_name.rb in sidekiq-throttled-0.8.2 vs lib/sidekiq/throttled/queue_name.rb in sidekiq-throttled-0.9.0
- old
+ new
@@ -5,11 +5,11 @@
# Queue name utility belt.
#
# @private
module QueueName
# RegExp used to stip out any redisr-namespace prefixes with `queue:`.
- QUEUE_NAME_PREFIX_RE = /^.*queue:/
+ QUEUE_NAME_PREFIX_RE = /.*queue:/
private_constant :QUEUE_NAME_PREFIX_RE
class << self
# Strips redis-namespace and `queue:` prefix from given queue name.
#
@@ -22,21 +22,21 @@
# # => "default"
#
# QueueName.normalize "foo:bar:queue:default"
# # => "default"
#
- # @param [String]
+ # @param [#to_s]
# @return [String]
def normalize(queue)
- queue.sub(QUEUE_NAME_PREFIX_RE, "")
+ queue.to_s.sub(QUEUE_NAME_PREFIX_RE, "")
end
# 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 [String] queue Queue name
+ # @param [#to_s] queue Queue name
# @return [String]
def expand(queue)
"queue:#{queue}"
end
end