Module: EQ::Queueing

Defined in:
lib/eq-queueing.rb,
lib/eq-queueing/queue.rb,
lib/eq-queueing/backends.rb

Defined Under Namespace

Modules: Backends Classes: Queue

Class Method Summary collapse

Class Method Details

.boot ⇒ Object 



8
9
10
 
# File 'lib/eq-queueing.rb', line 8

def boot
  EQ::Queueing::Queue.supervise_as :_eq_queueing, initialize_queueing_backend
end

.initialize_queueing_backend ⇒ Object

Raises:

  • ConfigurationError when EQ.config.queue is not supported



21
22
23
24
25
26
27
28
29
 
# File 'lib/eq-queueing.rb', line 21

def initialize_queueing_backend
  queue_config = EQ.config.send(EQ.config.queue)
  case EQ.config.queue
  when 'sequel'
    EQ::Queueing::Backends::Sequel.new queue_config
  else
    raise EQ::ConfigurationError, "EQ.config.queue = '#{EQ.config.queue}' is not supported!"
  end
end

.queue ⇒ Object 



16
17
18
 
# File 'lib/eq-queueing.rb', line 16

def queue
  Celluloid::Actor[:_eq_queueing]
end

.shutdown ⇒ Object 



12
13
14
 
# File 'lib/eq-queueing.rb', line 12

def shutdown
  queue.terminate! if queue
end