Class: Sidekiq::Client
- Inherits:
-
Object
- Object
- Sidekiq::Client
- Defined in:
- lib/sidekiq/client.rb
Class Method Summary collapse
- .default_middleware ⇒ Object
-
.enqueue(klass, *args) ⇒ Object
Redis compatibility helper.
-
.push(item) ⇒ Object
Example usage: Sidekiq::Client.push(‘queue’ => ‘my_queue’, ‘class’ => MyWorker, ‘args’ => [‘foo’, 1, :bat => ‘bar’]).
-
.queue_mappings ⇒ Object
DEPRECATED.
- .registered_queues ⇒ Object
- .registered_workers ⇒ Object
Class Method Details
.default_middleware ⇒ Object
9 10 11 12 13 |
# File 'lib/sidekiq/client.rb', line 9 def self.default_middleware Middleware::Chain.new do |m| m.add Middleware::Client::UniqueJobs end end |
.enqueue(klass, *args) ⇒ Object
60 61 62 |
# File 'lib/sidekiq/client.rb', line 60 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’])
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/sidekiq/client.rb', line 30 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'].['retry'] queue = item['queue'] || item['class'].['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| conn.multi do conn.sadd('queues', queue) conn.rpush("queue:#{queue}", payload) end end pushed = true end pushed end |
.queue_mappings ⇒ Object
DEPRECATED
24 25 26 |
# File 'lib/sidekiq/client.rb', line 24 def self.queue_mappings @queue_mappings ||= {} end |