lib/queue_bus/heartbeat.rb in queue-bus-0.5.4 vs lib/queue_bus/heartbeat.rb in queue-bus-0.5.5
- old
+ new
@@ -61,10 +61,10 @@
def set_saved_minute!(epoch_minute)
::QueueBus.redis { |redis| redis.set(redis_key, epoch_minute) }
end
- def perform
+ def perform(*args)
real_now = Time.now.to_i
run_until = lock! - 2
return if run_until < real_now
while((real_now = Time.now.to_i) < run_until)