Class: RocketJob::Config
- Inherits:
-
Object
- Object
- RocketJob::Config
- Includes:
- MongoMapper::Document, SyncAttr
- Defined in:
- lib/rocket_job/config.rb
Overview
Centralized Configuration for Rocket Jobs
Class Method Summary collapse
-
.mongo_connection=(connection) ⇒ Object
Replace the MongoMapper default mongo connection for holding jobs.
-
.mongo_work_connection ⇒ Object
Returns the Mongo connection for the Records and Results.
-
.mongo_work_connection=(connection) ⇒ Object
Use a separate Mongo connection for the Records and Results Allows the records and results to be stored in a separate Mongo database from the Jobs themselves.
Class Method Details
.mongo_connection=(connection) ⇒ Object
Replace the MongoMapper default mongo connection for holding jobs
52 53 54 55 56 57 58 59 60 61 62 63 64 65 |
# File 'lib/rocket_job/config.rb', line 52 def self.mongo_connection=(connection) connection(connection) Worker.connection(connection) Job.connection(connection) Config.connection(connection) DirmonEntry.connection(connection) db_name = connection.db.name set_database_name(db_name) Worker.set_database_name(db_name) Job.set_database_name(db_name) Config.set_database_name(db_name) DirmonEntry.set_database_name(db_name) end |
.mongo_work_connection ⇒ Object
Returns the Mongo connection for the Records and Results
81 82 83 |
# File 'lib/rocket_job/config.rb', line 81 def self.mongo_work_connection @@mongo_work_connection || connection end |
.mongo_work_connection=(connection) ⇒ Object
Use a separate Mongo connection for the Records and Results Allows the records and results to be stored in a separate Mongo database from the Jobs themselves.
It is recommended to set the work_connection to a local Mongo Worker that is not replicated to another data center to prevent flooding the network with replication of data records and results. The jobs themselves can/should be replicated across data centers so that they are never lost.
76 77 78 |
# File 'lib/rocket_job/config.rb', line 76 def self.mongo_work_connection=(connection) @@mongo_work_connection = connection end |