Module: Polipus::QueueOverflow

Defined in:
lib/polipus/queue_overflow.rb,
lib/polipus/queue_overflow/base.rb,
lib/polipus/queue_overflow/manager.rb,
lib/polipus/queue_overflow/mongo_queue.rb,
lib/polipus/queue_overflow/dev_null_queue.rb,
lib/polipus/queue_overflow/mongo_queue_capped.rb

Defined Under Namespace

Classes: Base, DevNullQueue, Manager, MongoQueue, MongoQueueCapped

Class Method Summary collapse

Class Method Details

.dev_null_queue(_options = {}) ⇒ Object 



20
21
22
23
 
# File 'lib/polipus/queue_overflow.rb', line 20

def self.dev_null_queue(_options = {})
  require 'polipus/queue_overflow/dev_null_queue'
  self::DevNullQueue.new
end

.mongo_queue(mongo_db, queue_name, options = {}) ⇒ Object 



5
6
7
8
9
10
 
# File 'lib/polipus/queue_overflow.rb', line 5

def self.mongo_queue(mongo_db, queue_name, options = {})
  require 'polipus/queue_overflow/mongo_queue'
  mongo_db ||= Mongo::Connection.new('localhost', 27_017, pool_size: 15, pool_timeout: 5).db('polipus')
  fail 'First argument must be an instance of Mongo::DB' unless mongo_db.is_a?(Mongo::DB)
  self::MongoQueue.new mongo_db, queue_name, options
end

.mongo_queue_capped(mongo_db, queue_name, options = {}) ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/polipus/queue_overflow.rb', line 12

def self.mongo_queue_capped(mongo_db, queue_name, options = {})
  require 'polipus/queue_overflow/mongo_queue_capped'
  mongo_db ||= Mongo::Connection.new('localhost', 27_017, pool_size: 15, pool_timeout: 5).db('polipus')
  fail 'First argument must be an instance of Mongo::DB' unless mongo_db.is_a?(Mongo::DB)
  options[:max] = 1_000_000 if options[:max].nil?
  self::MongoQueueCapped.new mongo_db, queue_name, options
end