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
Please use .push if possible instead.
- .middleware ⇒ Object
-
.push(queue = nil, item) ⇒ Object
Example usage: Sidekiq::Client.push(‘my_queue’, ‘class’ => MyWorker, ‘args’ => [‘foo’, 1, :bat => ‘bar’]).
- .queue_mappings ⇒ Object
- .registered_queues ⇒ Object
- .registered_workers ⇒ Object
Class Method Details
.default_middleware ⇒ Object
16 17 18 19 20 21 |
# File 'lib/sidekiq/client.rb', line 16 def self.default_middleware Middleware::Chain.new do |m| m.add Middleware::Client::UniqueJobs m.add Middleware::Client::ResqueWebCompatibility end end |
.enqueue(klass, *args) ⇒ Object
61 62 63 |
# File 'lib/sidekiq/client.rb', line 61 def self.enqueue(klass, *args) push(nil, { 'class' => klass.name, 'args' => args }) end |
.middleware ⇒ Object
12 13 14 |
# File 'lib/sidekiq/client.rb', line 12 def self.middleware raise "Sidekiq::Client.middleware is now Sidekiq.client_middleware" end |
.push(queue = nil, item) ⇒ Object
Example usage: Sidekiq::Client.push(‘my_queue’, ‘class’ => MyWorker, ‘args’ => [‘foo’, 1, :bat => ‘bar’])
37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/sidekiq/client.rb', line 37 def self.push(queue=nil, item) raise(ArgumentError, "Message must be a Hash of the form: { 'class' => SomeClass, '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'] queue = queue || queue_mappings[item['class'].to_s] || 'default' item['class'] = item['class'].to_s if !item['class'].is_a?(String) pushed = false Sidekiq.client_middleware.invoke(item, queue) do Sidekiq.redis.rpush("queue:#{queue}", MultiJson.encode(item)) pushed = true end pushed end |
.queue_mappings ⇒ Object
31 32 33 |
# File 'lib/sidekiq/client.rb', line 31 def self.queue_mappings @queue_mappings ||= {} end |