Class: Afterparty::Queue
- Inherits:
-
Object
- Object
- Afterparty::Queue
- Includes:
- QueueHelpers
- Defined in:
- lib/afterparty/queue.rb
Instance Attribute Summary collapse
-
#login_block ⇒ Object
Returns the value of attribute login_block.
-
#options ⇒ Object
Returns the value of attribute options.
-
#temp_namespace ⇒ Object
Returns the value of attribute temp_namespace.
Instance Method Summary collapse
- #pop ⇒ Object
- #push(job) ⇒ Object (also: #<<, #eng)
Methods included from QueueHelpers
#authenticate, #clear, #completed, #config_login, #handle_exception, #initialize, #jobs, #jobs_empty?, #last_completed, #next_valid_job, #run, #total_jobs_count, #valid_jobs
Instance Attribute Details
#login_block ⇒ Object
Returns the value of attribute login_block.
3 4 5 |
# File 'lib/afterparty/queue.rb', line 3 def login_block @login_block end |
#options ⇒ Object
Returns the value of attribute options.
3 4 5 |
# File 'lib/afterparty/queue.rb', line 3 def @options end |
#temp_namespace ⇒ Object
Returns the value of attribute temp_namespace.
3 4 5 |
# File 'lib/afterparty/queue.rb', line 3 def temp_namespace @temp_namespace end |
Instance Method Details
#pop ⇒ Object
13 14 15 16 17 18 19 20 21 |
# File 'lib/afterparty/queue.rb', line 13 def pop while true do unless (_job = next_valid_job).nil? _job.save return _job end sleep(@options[:sleep]) end end |
#push(job) ⇒ Object Also known as: <<, eng
6 7 8 9 |
# File 'lib/afterparty/queue.rb', line 6 def push job return nil if job.nil? AfterpartyJob.make_with_job job, @options[:namespace] end |