Class: Sidekiq::Haron::Transmitter

Inherits:
Object
  • Object
show all
Includes:
Storage
Defined in:
lib/sidekiq/haron/transmitter.rb

Constant Summary

Constants included from Storage

Storage::DEFAULT_EXPIRY

Constants included from Storage::RedisConverts

Storage::RedisConverts::CLASSES_TO_CONVERT

Instance Method Summary collapse

Methods included from Storage::RedisConverts

#decode_values_from, #encode_values_from

Instance Method Details

#clean(jid) ⇒ Object 



18
19
20
21
22
23
 
# 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) ⇒ Object 



11
12
13
14
15
16
 
# 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) ⇒ Object 



6
7
8
9
 
# 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 ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/sidekiq/haron/transmitter.rb', line 25

def tagged
  if ::Rails.logger.respond_to?(:tagged) && Sidekiq.logger.respond_to?(:tagged)
    ::Rails.logger.tagged(tags) do
      Sidekiq.logger.tagged(tags) do
        yield
      end
    end
  else
    yield
  end
end

#tags ⇒ Object 



37
38
39
 
# File 'lib/sidekiq/haron/transmitter.rb', line 37

def tags
  []
end