Class: Sidekiq::Promise::Middleware
- Inherits:
-
Object
- Object
- Sidekiq::Promise::Middleware
show all
- Defined in:
- lib/sidekiq/promise/middleware.rb
Constant Summary
collapse
- CHANNEL =
'/sidekiq_jobs'
Instance Method Summary
collapse
Instance Method Details
#job_completed(job, result = nil, redis_pool = Sidekiq.redis_pool) ⇒ Object
15
16
17
|
# File 'lib/sidekiq/promise/middleware.rb', line 15
def job_completed job, result=nil, redis_pool=Sidekiq.redis_pool
publish_message redis_pool, status: 'complete', job: job, jid: job['jid'], result: result
end
|
#job_dequeued(job, redis_pool = Sidekiq.redis_pool) ⇒ Object
11
12
13
|
# File 'lib/sidekiq/promise/middleware.rb', line 11
def job_dequeued job, redis_pool=Sidekiq.redis_pool
publish_message redis_pool, status: 'dequeued', job: job, jid: job['jid']
end
|
#job_enqueued(job, redis_pool = Sidekiq.redis_pool) ⇒ Object
7
8
9
|
# File 'lib/sidekiq/promise/middleware.rb', line 7
def job_enqueued job, redis_pool=Sidekiq.redis_pool
publish_message redis_pool, status: 'enqueued', job: job, jid: job['jid']
end
|
#job_errored(job, e, redis_pool = Sidekiq.redis_pool) ⇒ Object
19
20
21
|
# File 'lib/sidekiq/promise/middleware.rb', line 19
def job_errored job, e, redis_pool=Sidekiq.redis_pool
publish_message redis_pool, status: 'error', job: job, exception: {class: e.class.to_s, message: e.message, backtrace: e.backtrace}, jid: job['jid']
end
|
#publish_message(redis_pool, message) ⇒ Object
23
24
25
26
27
|
# File 'lib/sidekiq/promise/middleware.rb', line 23
def publish_message redis_pool, message
redis_pool.with do |redis|
redis.publish CHANNEL, message.to_json
end
end
|