module Polipus::QueueOverflow
Public Class Methods
dev_null_queue(_options = {})
click to toggle source
# File lib/polipus/queue_overflow.rb, line 21 def self.dev_null_queue(_options = {}) require 'polipus/queue_overflow/dev_null_queue' self::DevNullQueue.new end
mongo_queue(mongo_db, queue_name, options = {})
click to toggle source
# File lib/polipus/queue_overflow.rb, line 6 def self.mongo_queue(mongo_db, queue_name, options = {}) require 'polipus/queue_overflow/mongo_queue' mongo_db ||= Mongo::Client.new(['localhost:27_017'], database: 'polipus') fail 'First argument must be an instance of Mongo::Client' unless mongo_db.is_a?(Mongo::Client) self::MongoQueue.new mongo_db, queue_name, options end
mongo_queue_capped(mongo_db, queue_name, options = {})
click to toggle source
# File lib/polipus/queue_overflow.rb, line 13 def self.mongo_queue_capped(mongo_db, queue_name, options = {}) require 'polipus/queue_overflow/mongo_queue_capped' mongo_db ||= Mongo::Client.new(['localhost:27_017'], database: 'polipus') fail 'First argument must be an instance of Mongo::Client' unless mongo_db.is_a?(Mongo::Client) options[:max] = 1_000_000 if options[:max].nil? self::MongoQueueCapped.new mongo_db, queue_name, options end