Contents

module Magent
  class Channel < GenericChannel
    def enqueue(message, args)
      super([message, args])
    end

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

    def error_count
      error_collection.count()
    end

    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

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

    def retry_error(error)
      remove_error(error["_id"])
      enqueue(error["method"], error["payload"])
    end

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

Version data entries

5 entries across 5 versions & 2 rubygems

Version	Path
magent-0.4.2	lib/magent/channel.rb
thirtysixthspan-magent-0.4.1	lib/magent/channel.rb
magent-0.4	lib/magent/channel.rb
magent-0.3	lib/magent/channel.rb
magent-0.2	lib/magent/channel.rb