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