Class: Sidekiq::Qlimit::QlimitFetch::UnitOfWork

Inherits:
Struct
  • Object
show all
Defined in:
lib/sidekiq/qlimit/qlimit_fetch.rb

Overview

Qlimit aware UnitOfWork

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#job ⇒ Object

Returns the value of attribute job

Returns:

  • (Object) —

    the current value of job



37
38
39
 
# File 'lib/sidekiq/qlimit/qlimit_fetch.rb', line 37

def job
  @job
end

#queue ⇒ Object

Returns the value of attribute queue

Returns:

  • (Object) —

    the current value of queue



37
38
39
 
# File 'lib/sidekiq/qlimit/qlimit_fetch.rb', line 37

def queue
  @queue
end

Instance Method Details

#acknowledge ⇒ Object 



38
39
40
41
 
# File 'lib/sidekiq/qlimit/qlimit_fetch.rb', line 38

def acknowledge
  # Reduce qlimit on acknowledge
  QlimitFetch.qlimit_decrement(queue_name)
end

#queue_name ⇒ Object 



43
44
45
 
# File 'lib/sidekiq/qlimit/qlimit_fetch.rb', line 43

def queue_name
  queue.sub(/.*queue:/, ''.freeze)
end

#requeue ⇒ Object 



47
48
49
50
51
 
# File 'lib/sidekiq/qlimit/qlimit_fetch.rb', line 47

def requeue
  Sidekiq.redis do |conn|
    conn.rpush("queue:#{queue_name}", job)
  end
end