Module: Magent::Failure

Included in:
GenericChannel
Defined in:
lib/magent/failure.rb

Instance Method Summary collapse

Instance Method Details

#enqueue_error(error) ⇒ Object 



29
30
31
32
 
# File 'lib/magent/failure.rb', line 29

def enqueue_error(error)
  enqueue(error["message"], 1)
  remove_error(error["_id"])
end

#error_collection ⇒ Object 



34
35
36
 
# File 'lib/magent/failure.rb', line 34

def error_collection
  @error_collection ||= Magent.database.collection("#{@name}.errors")
end

#error_count ⇒ Object 



7
8
9
 
# File 'lib/magent/failure.rb', line 7

def error_count
  error_collection.count()
end

#errors(conds = {}) ⇒ Object 



11
12
13
14
15
16
17
18
 
# File 'lib/magent/failure.rb', line 11

def errors(conds = {})
  page = conds.delete(:page) || 1
  per_page = conds.delete(:per_page) || 10

  error_collection.find({}, {:skip => (page-1)*per_page,
                             :limit => per_page,
                             :sort => [["created_at", -1]]})
end

#failed(info) ⇒ Object 



3
4
5
 
# File 'lib/magent/failure.rb', line 3

def failed(info)
  error_collection.save(info.merge({:_id => generate_uid, :channel => @name, :channel_class => self.class.to_s, :created_at => Time.now.utc}))
end

#remove_error(error_id) ⇒ Object 



20
21
22
 
# File 'lib/magent/failure.rb', line 20

def remove_error(error_id)
  self.error_collection.remove(:_id => error_id)
end

#retry_error(error) ⇒ Object 



24
25
26
27
 
# File 'lib/magent/failure.rb', line 24

def retry_error(error)
  process!(error["message"])
  remove_error(error["_id"])
end