Module: Polipus::QueueOverflow
- Defined in:
- lib/polipus/queue_overflow.rb,
lib/polipus/queue_overflow/base.rb,
lib/polipus/queue_overflow/worker.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, Worker
Class Method Summary
collapse
Class Method Details
.dev_null_queue(_options = {}) ⇒ Object
21
22
23
24
|
# 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 = {}) ⇒ Object
6
7
8
9
10
11
|
# 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 = {}) ⇒ Object
13
14
15
16
17
18
19
|
# 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
|