class Sidekiq::Haron::Transmitter
Public Instance Methods
clean(jid)
click to toggle source
# File lib/sidekiq/haron/transmitter.rb, line 18 def clean jid clean_for_id(jid) rescue => e Sidekiq.logger.error "clean error #{jid} - #{e.to_s}" nil end
load(jid)
click to toggle source
# File lib/sidekiq/haron/transmitter.rb, line 11 def load jid load_data read_for_id(jid) rescue => e Sidekiq.logger.error "loading data error #{jid} - #{e.to_s}" {} end
save(worker_class, msg, queue, redis_pool)
click to toggle source
# File lib/sidekiq/haron/transmitter.rb, line 6 def save worker_class, msg, queue, redis_pool data = saved_data(worker_class, msg, queue) store_for_id msg['jid'], data, redis_pool end
tagged() { || ... }
click to toggle source
# File lib/sidekiq/haron/transmitter.rb, line 25 def tagged ::Rails.logger.tagged(tags) do Sidekiq.logger.tagged(tags) do yield end end end
Private Instance Methods
load_data()
click to toggle source
# File lib/sidekiq/haron/transmitter.rb, line 44 def load_data raise NotImplemented end
saved_data()
click to toggle source
# File lib/sidekiq/haron/transmitter.rb, line 40 def saved_data raise NotImplemented end