Method: Resque::Scheduler::DelayingExtensions#delayed_timestamp_peek
- Defined in:
- lib/resque/scheduler/delaying_extensions.rb
#delayed_timestamp_peek(timestamp, start, count) ⇒ Object
Returns an array of delayed items for the given timestamp
96 97 98 99 100 101 102 103 |
# File 'lib/resque/scheduler/delaying_extensions.rb', line 96 def (, start, count) if 1 == count r = list_range "delayed:#{timestamp.to_i}", start, count r.nil? ? [] : [r] else list_range "delayed:#{timestamp.to_i}", start, count end end |