class Sidekiq::Promise::Middleware
Constants
- CHANNEL
Public Instance Methods
job_completed(job, result=nil, redis_pool=Sidekiq::Promise.redis_pool)
click to toggle source
# File lib/sidekiq/promise/middleware.rb, line 15 def job_completed job, result=nil, redis_pool=Sidekiq::Promise.redis_pool publish_message redis_pool, status: 'complete', job: job, jid: job['jid'], result: result end
job_dequeued(job, redis_pool=Sidekiq::Promise.redis_pool)
click to toggle source
# File lib/sidekiq/promise/middleware.rb, line 11 def job_dequeued job, redis_pool=Sidekiq::Promise.redis_pool publish_message redis_pool, status: 'dequeued', job: job, jid: job['jid'] end
job_enqueued(job, redis_pool=Sidekiq::Promise.redis_pool)
click to toggle source
# File lib/sidekiq/promise/middleware.rb, line 7 def job_enqueued job, redis_pool=Sidekiq::Promise.redis_pool publish_message redis_pool, status: 'enqueued', job: job, jid: job['jid'] end
job_errored(job, e, redis_pool=Sidekiq::Promise.redis_pool)
click to toggle source
# File lib/sidekiq/promise/middleware.rb, line 19 def job_errored job, e, redis_pool=Sidekiq::Promise.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)
click to toggle source
# 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