Class: AtomicSidekiq::InFlightQueue

Inherits:
Object
  • Object
show all
Defined in:
lib/atomic_sidekiq/in_flight_queue.rb

Instance Method Summary collapse

Constructor Details

#initializeInFlightQueue

Returns a new instance of InFlightQueue.



3
4
5
# File 'lib/atomic_sidekiq/in_flight_queue.rb', line 3

def initialize
  @keymaker = InFlightKeymaker.new(AtomicFetch::IN_FLIGHT_KEY_PREFIX)
end

Instance Method Details

#listObject



7
8
9
10
# File 'lib/atomic_sidekiq/in_flight_queue.rb', line 7

def list
  keys = list_keys
  retrieve_jobs(keys)
end