Class: Sidekiq::Client

Inherits:
Object
  • Object
show all
Defined in:
lib/sidekiq/client.rb

Class Method Summary collapse

Class Method Details

.default_middleware ⇒ Object 



9
10
11
12
 
# File 'lib/sidekiq/client.rb', line 9

def self.default_middleware
  Middleware::Chain.new do |m|
  end
end

.enqueue(klass, *args) ⇒ Object

Redis compatibility helper. Example usage:

Sidekiq::Client.enqueue(MyWorker, 'foo', 1, :bat => 'bar')

Messages are enqueued to the ‘default’ queue.



58
59
60
 
# File 'lib/sidekiq/client.rb', line 58

def self.enqueue(klass, *args)
  push('class' => klass, 'args' => args)
end

.push(item) ⇒ Object

Example usage: Sidekiq::Client.push(‘queue’ => ‘my_queue’, ‘class’ => MyWorker, ‘args’ => [‘foo’, 1, :bat => ‘bar’])

Raises:

  • (ArgumentError) 


29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/sidekiq/client.rb', line 29

def self.push(item)
  raise(ArgumentError, "Message must be a Hash of the form: { 'class' => SomeWorker, 'args' => ['bob', 1, :foo => 'bar'] }") unless item.is_a?(Hash)
  raise(ArgumentError, "Message must include a class and set of arguments: #{item.inspect}") if !item['class'] || !item['args']
  raise(ArgumentError, "Message must include a Sidekiq::Worker class, not class name: #{item['class'].ancestors.inspect}") if !item['class'].is_a?(Class) || !item['class'].respond_to?('get_sidekiq_options')

  item['retry'] = !!item['class'].get_sidekiq_options['retry']
  queue = item['queue'] || item['class'].get_sidekiq_options['queue'] || queue_mappings[item['class'].to_s] || 'default'
  worker_class = item['class']
  item['class'] = item['class'].to_s

  pushed = false
  Sidekiq.client_middleware.invoke(worker_class, item, queue) do
    payload = MultiJson.encode(item)
    Sidekiq.redis do |conn|
      _, pushed = conn.multi do
        conn.sadd('queues', queue)
        conn.rpush("queue:#{queue}", payload)
      end
    end
  end
  !! pushed
end

.queue_mappings ⇒ Object

DEPRECATED



23
24
25
 
# File 'lib/sidekiq/client.rb', line 23

def self.queue_mappings
  @queue_mappings ||= {}
end

.registered_queues ⇒ Object 



18
19
20
 
# File 'lib/sidekiq/client.rb', line 18

def self.registered_queues
  Sidekiq.redis { |x| x.smembers('queues') }
end

.registered_workers ⇒ Object 



14
15
16
 
# File 'lib/sidekiq/client.rb', line 14

def self.registered_workers
  Sidekiq.redis { |x| x.smembers('workers') }
end