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
tags() click to toggle source
# File lib/sidekiq/haron/transmitter.rb, line 34
def tags
  []
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