We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3d9c45a commit 02a6ac1Copy full SHA for 02a6ac1
lib/resque.rb
@@ -102,19 +102,13 @@ def queues
102
103
# Given a queue name, completely deletes the queue.
104
def remove_queue(queue)
105
- @watched_queues ||= {}
106
- @watched_queues.delete(queue.to_s)
107
redis.srem(:queues, queue.to_s)
108
redis.del("queue:#{queue}")
109
end
110
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
117
- return if @watched_queues[queue]
118
redis.sadd(:queues, queue.to_s)
119
120
0 commit comments