module RedisQueue::RestoreBackupLimit

Constants

BACKUP_COUNT_KEY
BACKUP_LIMIT

Public Instance Methods

filter_backup_element(element) click to toggle source
# File lib/redis-call/redis_queue.rb, line 212
def filter_backup_element element
  result = decode_json(element)
  
  if result.is_a?(Hash)
    result[BACKUP_COUNT_KEY] ||= 0
    result[BACKUP_COUNT_KEY] += 1
    
    if result[BACKUP_COUNT_KEY] > BACKUP_LIMIT
      error_push_raw encode_json(result)
      return nil
    else
      return encode_json(result)
    end
    
  else
    element
  end
end