Module: Sidekiq::Worker
- Defined in:
- lib/sidekiq/worker.rb,
lib/sidekiq/testing.rb
Overview
Include this module in your worker class and you can easily create asynchronous jobs:
class HardWorker
include Sidekiq::Worker
def perform(*args)
# do some work
end
end
Then in your Rails app, you can do this:
HardWorker.perform_async(1, 2, 3)
Note that perform_async is a class method, perform is an instance method.
Defined Under Namespace
Modules: ClassMethods, Options Classes: Setter
Instance Attribute Summary collapse
-
#jid ⇒ Object
Returns the value of attribute jid.
Class Method Summary collapse
-
.clear_all ⇒ Object
Clear all queued jobs across all workers.
-
.drain_all ⇒ Object
Drain all queued jobs across all workers.
- .included(base) ⇒ Object
-
.jobs ⇒ Object
:nodoc:.
Instance Method Summary collapse
Instance Attribute Details
#jid ⇒ Object
Returns the value of attribute jid.
135 136 137 |
# File 'lib/sidekiq/worker.rb', line 135 def jid @jid end |
Class Method Details
.clear_all ⇒ Object
Clear all queued jobs across all workers
310 311 312 |
# File 'lib/sidekiq/testing.rb', line 310 def clear_all Queues.clear_all end |
.drain_all ⇒ Object
Drain all queued jobs across all workers
315 316 317 318 319 320 321 322 323 |
# File 'lib/sidekiq/testing.rb', line 315 def drain_all while jobs.any? worker_classes = jobs.map { |job| job["class"] }.uniq worker_classes.each do |worker_class| Sidekiq::Testing.constantize(worker_class).drain end end end |
.included(base) ⇒ Object
137 138 139 140 141 142 |
# File 'lib/sidekiq/worker.rb', line 137 def self.included(base) raise ArgumentError, "Sidekiq::Worker cannot be included in an ActiveJob: #{base.name}" if base.ancestors.any? { |c| c.name == "ActiveJob::Base" } base.include(Options) base.extend(ClassMethods) end |
.jobs ⇒ Object
:nodoc:
305 306 307 |
# File 'lib/sidekiq/testing.rb', line 305 def jobs # :nodoc: Queues.jobs_by_queue.values.flatten end |