Class: AtomicSidekiq::AtomicOperation::Retrieve
- Defined in:
- lib/atomic_sidekiq/atomic_operation/retrieve.rb
Constant Summary collapse
- RETRIEVE_SCRIPT =
File.read( File.join(File.dirname(__FILE__), "./lua_scripts/retrieve.lua") )
Instance Method Summary collapse
Methods inherited from Base
Constructor Details
This class inherits a constructor from AtomicSidekiq::AtomicOperation::Base
Instance Method Details
#perform(queues, expire_at) ⇒ Object
9 10 11 12 13 14 15 |
# File 'lib/atomic_sidekiq/atomic_operation/retrieve.rb', line 9 def perform(queues, expire_at) queues.each do |queue| res = retrieve_from_queue(queue, expire_at.to_i) return res if res end nil end |