Sha256: ae8182a0b40990c0d514bb12c7f3d0fa032800cfa5e2d1a065bbe01f79be896e

Contents?: true

Size: 245 Bytes

Versions: 2

Compression:

Stored size: 245 Bytes

Contents

Resque.send(:define_singleton_method, :queues) do
  data_store.queue_names.reject { |name| name.start_with?(Resque::Plugins::Fifo::WORKER_QUEUE_NAMESPACE) }
end

Resque.send(:define_singleton_method, :all_queues) do
  data_store.queue_names
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
resque-fifo-queue-0.1.2 lib/resque/plugins/fifo/extensions.rb
resque-fifo-queue-0.1.1 lib/resque/plugins/fifo/extensions.rb