We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6c8ed8f commit 0f296e3Copy full SHA for 0f296e3
lib/resque.rb
@@ -111,6 +111,8 @@ def remove_queue(queue)
111
# Used internally to keep track of which queues we've created.
112
# Don't call this directly.
113
def watch_queue(queue)
114
+ # In order to avoid hitting Redis every time a job is queued we
115
+ # cache the list of known queues.
116
@watched_queues ||= {}
117
return if @watched_queues[queue]
118
redis.sadd(:queues, queue.to_s)
0 commit comments